US 11,789,771 B2
Method and apparatus for a step-enabled workflow
Iraj Sodagar, Los Angeles, CA (US)
Assigned to Tencent America LLC, Palo Alto, CA (US)
Filed by Tencent America LLC, Palo Alto, CA (US)
Filed on Sep. 17, 2020, as Appl. No. 17/24,193.
Claims priority of provisional application 62/907,627, filed on Sep. 28, 2019.
Claims priority of provisional application 62/907,625, filed on Sep. 28, 2019.
Prior Publication US 2021/0096903 A1, Apr. 1, 2021
Int. Cl. G06F 9/48 (2006.01); G06F 9/54 (2006.01); G06Q 10/10 (2023.01); G06Q 10/0633 (2023.01); G06Q 10/0631 (2023.01)
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
OG exemplary drawing
 
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.