Skip to content
This repository has been archived by the owner on Dec 13, 2023. It is now read-only.

Fix next task not scheduled after switch completes #3197

Merged
merged 1 commit into from
Aug 24, 2022

Conversation

jxu-nflx
Copy link
Contributor

Pull Request type

  • Bugfix
  • Feature
  • Refactoring (no functional changes, no api changes)
  • Build related changes (Please run ./gradlew generateLock saveLock to refresh dependencies)
  • WHOSUSING.md
  • Other (please describe):

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

Changes in this PR

Revert changes done to SwitchTaskMapper introduced by this PR, and add test case to verify the fix.

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

Alternatives considered

Describe alternative implementation you have considered

@jxu-nflx jxu-nflx force-pushed the bugfix/workflow_hanging_after_switch_task branch from f3ef76e to 531714e Compare August 23, 2022 22:44
@hebrd
Copy link

hebrd commented Aug 23, 2022

@jxu-nflx Would you please kindly advise If this PR fixed only switch task or applicable for all kinds of tasks? i.e. fixed the issue #3089 completely?

@v1r3n
Copy link
Contributor

v1r3n commented Aug 24, 2022

@jxu-nflx Would you please kindly advise If this PR fixed only switch task or applicable for all kinds of tasks? i.e. fixed the issue #3089 completely?

Yes this will fix #3089

@hebrd
Copy link

hebrd commented Aug 24, 2022

@jxu-nflx Would you please kindly advise If this PR fixed only switch task or applicable for all kinds of tasks? i.e. fixed the issue #3089 completely?

Yes this will fix #3089

So great. Looking forward to the release including this PR.

@@ -96,8 +96,7 @@ public List<TaskModel> getMappedTasks(TaskMapperContext taskMapperContext) {
switchTask.getInputData().put("case", evalResult);
switchTask.getOutputData().put("evaluationResult", Collections.singletonList(evalResult));
switchTask.setStartTime(System.currentTimeMillis());
switchTask.setStatus(TaskModel.Status.COMPLETED);
switchTask.setExecuted(true);
switchTask.setStatus(TaskModel.Status.IN_PROGRESS);
Copy link
Contributor

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

The switch task is completed here so the status should be COMPLETED .Only executed flag has to be removed.

Copy link
Contributor Author

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

It will be marked as completed in the executor

@jxu-nflx
Copy link
Contributor Author

@jxu-nflx Would you please kindly advise If this PR fixed only switch task or applicable for all kinds of tasks? i.e. fixed the issue #3089 completely?

This is the fix just for the switch task

@jxu-nflx jxu-nflx merged commit 630b870 into main Aug 24, 2022
@jxu-nflx jxu-nflx deleted the bugfix/workflow_hanging_after_switch_task branch August 24, 2022 17:07
pmchung pushed a commit to routific/conductor that referenced this pull request Sep 6, 2023
Sign up for free to subscribe to this conversation on GitHub. Already have an account? Sign in.
Labels
None yet
Projects
None yet
Development

Successfully merging this pull request may close these issues.

5 participants