Task runners call
report_task_progress
when
assigned a task to acknowledge that it has the task. If the web service
does not receive this acknowledgement within 2 minutes, it assigns the
task in a subsequent poll_for_task
call.
After this initial acknowledgement, the task runner only needs to report
progress every 15 minutes to maintain its ownership of the task. You can
change this reporting time from 15 minutes by specifying a
reportProgressTimeout
field in your pipeline.
If a task runner does not report its status after 5 minutes, AWS Data
Pipeline assumes that the task runner is unable to process the task and
reassigns the task in a subsequent response to
poll_for_task
. Task runners should call
report_task_progress
every 60
seconds.
datapipeline_report_task_progress(taskId, fields)
[required] The ID of the task assigned to the task runner. This value is provided
in the response for poll_for_task
.
Key-value pairs that define the properties of the ReportTaskProgressInput object.
A list with the following syntax:
list( canceled = TRUE|FALSE )
svc$report_task_progress( taskId = "string", fields = list( list( key = "string", stringValue = "string", refValue = "string" ) ) )