Skip to content

Conversation

shaileshpadave
Copy link
Contributor

Pull Request type

  • Bugfix
  • Feature
  • Refactoring (no functional changes, no api changes)
  • Build related changes
  • WHOSUSING.md
  • Other (please describe):

NOTE: Please remember to run ./gradlew spotlessApply to fix any format violations.

Changes in this PR

  • Introduce Signal API and SYNC-DURABLE consisteny during execution

Describe the new behavior from this PR, and why it's needed
Issue #

Alternatives considered

Describe alternative implementation you have considered

@shaileshpadave shaileshpadave force-pushed the wfClientExecute branch 9 times, most recently from 4dd6550 to af08882 Compare April 17, 2025 05:51
* @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,
Copy link
Collaborator

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>

Copy link
Contributor Author

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 ?

Copy link
Contributor

@VerstraeteBert VerstraeteBert left a 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?

@v1r3n v1r3n closed this Jun 8, 2025
@v1r3n v1r3n reopened this Jun 8, 2025
@shaileshpadave shaileshpadave force-pushed the wfClientExecute branch 2 times, most recently from e6092a2 to 80b8b6f Compare June 9, 2025 18:56
- Add SignalResponse model with helper methods
- Add ReturnStrategy enum support
- Update TaskClient and WorkflowClient APIs
- Add comprehensive test coverage
- Maintain backward compatibility

import lombok.Data;

@Data
Copy link
Contributor

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

Copy link
Contributor Author

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

@v1r3n v1r3n merged commit 85ec017 into main Jun 12, 2025
7 checks passed
@v1r3n v1r3n deleted the wfClientExecute branch June 12, 2025 06:46
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
None yet
Projects
None yet
Development

Successfully merging this pull request may close these issues.

4 participants