Skip to content
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

Add total timeout backend #318

Open
wants to merge 9 commits into
base: main
Choose a base branch
from

Conversation

shaileshpadave
Copy link
Contributor

@shaileshpadave shaileshpadave commented Nov 25, 2024

Pull Request type

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

Changes in this PR

Code changes to check if total task timeout has reached or not, if yes then workflow should be terminated.

@@ -47,6 +47,8 @@ public enum RetryLogic {

Copy link
Contributor

Choose a reason for hiding this comment

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

@shaileshpadave anything that's under conductor-clients/java/conductor-java-sdk/ is part of the Java Client v4 project.

Let's keep the conductor core changes and client changes in separate PRs

Copy link
Contributor Author

Choose a reason for hiding this comment

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

ACK

@shaileshpadave shaileshpadave force-pushed the addTotalTimeout_backend branch from e922fff to e0174b6 Compare November 27, 2024 11:26
@shaileshpadave shaileshpadave marked this pull request as ready for review November 29, 2024 07:27
@@ -498,6 +498,7 @@ public void testTaskTimeout() {
taskType.setName("test");
taskType.setTimeoutPolicy(TimeoutPolicy.RETRY);
taskType.setTimeoutSeconds(1);
taskType.setTotalTimeoutSeconds(1_000);
Copy link
Contributor

Choose a reason for hiding this comment

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

  • Why a 1000 second total timeout for this test?
  • Is this test covering the changes made to checkTaskTimeout?

}

String reason =
String.format(
"Task timed out after %d seconds. Timeout configured as %d seconds. "
+ "Total Task Timeout configured as %d seconds. "
Copy link
Contributor

@jmigueprieto jmigueprieto Dec 2, 2024

Choose a reason for hiding this comment

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

This reason may be confusing.

It's not immediately clear which timeout kicked in since it's mentioning both (timeout and total timeout).

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.

2 participants