conductor icon indicating copy to clipboard operation
conductor copied to clipboard

Timeout and retry.

Open preeth-gopalakrishnan opened this issue 6 years ago • 2 comments

Hello, working on 1.8.2. I have a query regarding the timeout and retry for simple tasks. simple task definition. { "name": "test_task", "taskReferenceName": "test_task_1", "retryCount": 3, "timeoutSeconds": 10, "inputParameters": { "stayId": "${workflow.input.aTestInput}" }, "timeoutPolicy": "RETRY", "retryLogic": "FIXED", "retryDelaySeconds": 10, "type": "SIMPLE" }

If the task is taking more time than the timeoutSeconds, then will the task be re scheduled. If so how many times. Which property controls this behavior? Currently I am seeing this task being attempted around 18 times, out of which 14 were retries (task.isRetried() == true), But in the UI execution flow, there are only 4 executions.

preeth-gopalakrishnan avatar Mar 05 '18 14:03 preeth-gopalakrishnan

@preeth-gopalakrishnan try using responseTimeoutSeconds https://netflix.github.io/conductor/metadata/

pctreddy avatar Mar 06 '18 22:03 pctreddy

Hello, have updated the task definition with the response timeout as 10 seconds. I have a simple worker associated with the task, which sleeps for 40 seconds and updates the task result as completed. I was expecting the task to be re scheduled, But did not do so. Is this correct understanding.

@Override public TaskResult execute(Task task) { TaskResult result = new TaskResult(task); Thread.sleep(40*1000); result.setStatus(Status.COMPLETED); return result; }

Task definition. { "name": "test_task", "taskReferenceName": "test_task_1", "retryCount": 3, "timeoutSeconds": 10, "inputParameters": { "stayId": "${workflow.input.aTestInput}" }, "timeoutPolicy": "RETRY", "retryLogic": "FIXED", "retryDelaySeconds": 10, "responseTimeoutSeconds": 10, "type": "SIMPLE" }

preeth-gopalakrishnan avatar Mar 07 '18 16:03 preeth-gopalakrishnan