-
Notifications
You must be signed in to change notification settings - Fork 692
Introduce Signal API and SYNC-DURABLE consisteny during execution #481
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
Conversation
4dd6550
to
af08882
Compare
* @param consistency Execution consistency mode (DURABLE or SYNC) | ||
* @return A CompletableFuture containing the TaskRun with blocking task details including input data | ||
*/ | ||
public CompletableFuture<TaskRun> executeWorkflowWithBlockingTaskInput(StartWorkflowRequest req, |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
This should be INPUT which is a Map<String, Object>
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
We usually accept StartWorkflowRequest which contains all the information from Request body right ?
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
What is the meaning and behaviour? of this workflow consistency and signals? Could you elaborate in the PR description?
e6092a2
to
80b8b6f
Compare
- Add SignalResponse model with helper methods - Add ReturnStrategy enum support - Update TaskClient and WorkflowClient APIs - Add comprehensive test coverage - Maintain backward compatibility
5d2ebd1
to
b5a3a3d
Compare
|
||
import lombok.Data; | ||
|
||
@Data |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
annotations like other pojos. please check
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
updated code with similar annotation on other pojos
7efded5
to
29ff312
Compare
29ff312
to
7c72af5
Compare
c7bac00
to
74f41a4
Compare
Pull Request type
NOTE: Please remember to run
./gradlew spotlessApply
to fix any format violations.Changes in this PR
Describe the new behavior from this PR, and why it's needed
Issue #
Alternatives considered
Describe alternative implementation you have considered