fix time out

Netflix · Nov 27, 2023 · db047c5 · db047c5
1 parent fb70f49
commit db047c5
Showing 1 changed file with 7 additions and 3 deletions.
diff --git a/core/src/main/java/com/netflix/conductor/core/reconciliation/WorkflowSweeper.java b/core/src/main/java/com/netflix/conductor/core/reconciliation/WorkflowSweeper.java
@@ -149,9 +149,13 @@ void unack(WorkflowModel workflowModel, long workflowOffsetTimeout) {
                         postponeDurationSeconds = taskDef.getPollTimeoutSeconds() + 1;
                     } else {
                         postponeDurationSeconds =
-                                (workflowModel.getWorkflowDefinition().getTimeoutSeconds() != 0)
-                                        ? workflowModel.getWorkflowDefinition().getTimeoutSeconds()
-                                                + 1
+                                workflowModel.getWorkflowDefinition().getTimeoutSeconds();
+                        if (postponeDurationSeconds > taskModel.getResponseTimeoutSeconds()) {
+                            postponeDurationSeconds = taskModel.getResponseTimeoutSeconds();
+                        }
+                        postponeDurationSeconds =
+                                (postponeDurationSeconds != 0)
+                                        ? postponeDurationSeconds + 1
                                         : workflowOffsetTimeout;
                     }
                 } else {