CPC G06F 9/485 (2013.01) [G06F 9/4881 (2013.01); G06F 9/542 (2013.01); G06F 9/544 (2013.01); G06Q 10/0633 (2013.01); G06Q 10/06316 (2013.01); G06Q 10/103 (2013.01)] | 19 Claims |
1. A method for processing a workflow, the method comprising:
receiving, by processing circuitry, workflow information of the workflow;
generating, based on the workflow information, the workflow to process input data, the workflow including a plurality of processing tasks and a first buffering task, the plurality of processing tasks including a first processing task and a second processing task, each of the plurality of processing tasks being associated with a respective task segment duration (TSD) and configured to process an amount of data associated with the respective TSD independently from other data;
causing the first processing task to enter a running state in which a subset of the input data is processed by the first processing task and output to the first buffering task as first processed subset data;
causing the first processing task to transition from the running state to a non-running state based on an amount of the first processed subset data stored in the first buffering task being equal to a first threshold, the first threshold being based on one of (i) TSDs associated with the plurality of processing tasks, (ii) a workflow segment duration (WSD) equal to a least common multiple of the TSDs, or (iii) the WSD and a parameter S that indicates a number of steps that the first processing task is configured to run consecutively; and
after the first processing task is transitioned to the non-running state, causing the second processing task to enter a running state in which the first processed subset data stored in the first buffering task is processed by the second processing task.
|