CPC G06F 9/4881 (2013.01) [G06F 9/485 (2013.01)] | 27 Claims |
1. An apparatus comprising at least one processor and a storage to store instructions that, when executed by the at least one processor, cause the at least one processor to perform operations comprising:
within a kill container, the at least one processor is caused to perform operations comprising:
monitor a task kill queue for error messages that each indicate an occurrence of an error in executing a task routine to perform a task of a set of tasks of a job flow, and for messages that each indicate a successful execution of a task routine to perform a task of the set of tasks;
in response to output, onto the task kill queue, of a first set of error messages indicative of errors in executing multiple instances of a first task routine to perform a first task of the set of tasks with multiple data object blocks of a data object, compare a quantity of error messages within of the first set of error messages to a first predetermined threshold quantity;
in response to a lack of receipt, via the task kill queue, of a message that indicates a successful execution of an instance of the first task routine, and in response to the quantity of error messages within the first set of error messages reaching the first predetermined threshold quantity, output a kill tasks request message that identifies the job flow onto the task kill queue; and
in response to output, onto the task kill queue, of at least one message that indicates a successful execution of an instance of the first task routine, increase the first predetermined threshold quantity or refrain from outputting the kill tasks request message;
within at least one task container of a set of task containers, and in response to the output of the kill tasks request message onto the task kill queue, the at least one processor is caused to perform operations comprising:
cease execution of the first task routine to cancel the performance of the first task; and
output, onto a task queue, a task cancelation message indicative of cessation of execution of the first task routine, and that identifies the first task and the job flow; and
within a performance container, and in response to the output of the task cancelation message onto the task queue, the at least one processor is caused to perform operations comprising:
output a job cancelation message indicative of cancelation of the job flow onto a job queue to cause a transmission of an indication of cancelation of the job flow, via a network, and to a requesting device that requested the performance of the job flow.
|