conductor
conductor copied to clipboard
Timeout and retry.
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 try using responseTimeoutSeconds
https://netflix.github.io/conductor/metadata/
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" }