Signaling timeout and complete data inputs in cloud workflows

1. A method for network based media processing (NBMP), the method comprising:

obtaining an input of at least one of a task and a workflow in NBMP;

setting a timeout for the input of the at least one of the task and the workflow;

determining whether the at least one of the task and the workflow observes a lack of data of the input for a duration equal to the timeout;

determining, in response to determining that the at least one of the task and the workflow observed the lack of data of the input for the duration equal to the timeout, an unavailability of further data of the input;

determining whether each of inputs, including the input, of the at least one of the task and the workflow is to be respectively associated to at least one of inputs and outputs of one or more functions respectively by determining at least ones of an identification and a port name for each of the inputs of the at least one of the task and the workflow and at least ones of a corresponding port name and a stream identification of at least ones of a corresponding input port and output port;

respectively associating, based on determining whether each of the inputs of the at least one of the task and the workflow is to be respectively associated to at least one of inputs and outputs of one or more functions respectively, the inputs of the at least one of the task and the workflow with the at least ones of the inputs and the outputs of the one or more functions;

applying an update to the at least one of the task and the workflow in NBMP based on determining the unavailability of further data of the input; and

processing the at least one of the task and the workflow in NBMP based on the update.

2. The method according to claim 1 , further comprising:

determining whether a state of the at least one of the task and the workflow is set to a running state; and

determining, in a case where it is determined that the state is set to the running state, whether to change the state from the running state to an idle state based on whether the at least one of the task and the workflow observes the lack of data of the input for a duration equal to the timeout.

3. The method according to claim 1 , further comprising:

determining whether the input comprises an indication; and

determining, in response to determining that the input comprises the indication, the unavailability of further data of the input.

4. The method according to claim 3 ,

wherein the indication comprises a complete input flag included with the input of the at least one of the task and the workflow.

5. The method according to claim 3 ,

wherein the indication is included in metadata provided with the input of the at least one of the task and the workflow.

6. The method according to claim 3 , further comprising:

obtaining the plurality of inputs, including the input, of the at least one of the task and the workflow;

determining whether a state of the at least one of the task and the workflow is set to a running state;

determining whether all of the inputs of the at least one of the task and the workflow observes the lack of data of all of the inputs for the duration equal to the timeout; and

determining, in a case where it is determined that the state is set to the running state, whether to change the state from the running state to an idle state based on whether the at least one of the task and the workflow observes the lack of data of the input for a duration equal to the timeout for all of the inputs.

7. The method according to claim 6 ,

wherein determining whether all of the inputs of the at least one of the task and the workflow observes the lack of data of all of the inputs for the duration equal to the timeout comprises determining whether at least one of the inputs of the at least one of the task and the workflow indicates any of a timeout indication and a complete indication.

8. An apparatus for network based media processing (NBMP), the apparatus comprising:

at least one memory configured to store computer program code;

at least one processor configured to access the computer program code and operate as instructed by the computer program code, the computer program code including:

obtaining code configured to cause the at least one processor to obtain an input of at least one of a task and a workflow in NBMP;

setting code configured to cause the at least one processor to set a timeout for the input of the at least one of the task and the workflow; and

determining code configured to cause the at least one processor to determine whether the at least one of the task and the workflow observes a lack of data of the input for a duration equal to the timeout;

wherein the determining code is further configured to cause the at least one processor to determine, in response to determining that the at least one of the task and the workflow observed the lack of data of the input for the duration equal to the timeout, an unavailability of further data of the input;

wherein the computer program code further comprises applying code configured to cause the at least one processor to apply an update to the at least one of the task and the workflow in NBMP based on determining the unavailability of further data of the input; and

wherein the computer program code further comprises processing code configured to cause the at least one processor to process the at least one of the task and the workflow in NBMP based on the update,

wherein the determining code is further configured to cause the at least one processor to determine whether each of inputs, including the input, of the at least one of the task and the workflow is to be respectively associated to at least one of inputs and outputs of one or more functions respectively by determining at least ones of an identification and a port name for each of the inputs of the at least one of the task and the workflow and at least ones of a corresponding port name and a stream identification of at least ones of a corresponding input port and output port;

wherein the computer program code further comprises associating code figured to cause the at least one processor to respectively associate, based on determining whether each of the inputs of the at least one of the task and the workflow is to be respectively associated to at least one of inputs and outputs of one or more functions respectively, the inputs of the at least one of the task and the workflow with the at least ones of the inputs and the outputs of the one or more functions.

9. The apparatus according to claim 8 ,

wherein the determining code is further configured to cause the at least one processor to determine, whether a state of the at least one of the task and the workflow is set to a running state, and

wherein the determining code is further configured to cause the at least one processor to determine, in a case where it is determined that the state is set to the running state, whether to change the state from the running state to an idle state based on whether the at least one of the task and the workflow observes the lack of data of the input for a duration equal to the timeout.

10. The apparatus according to claim 8 ,

wherein the determining code is further configured to cause the at least one processor to determine whether the input comprises an indication, and

wherein the determining code is further configured to cause the at least one processor to determine, in response to determining that the input comprises the indication, the unavailability of further data of the input.

11. The apparatus for according to 10 ,

wherein the indication comprises a complete input flag included with the input of the at least one of the task and the workflow.

12. The apparatus for according to claim 10 ,

wherein the indication is included in metadata provided with the input of the at least one of the task and the workflow.

13. The apparatus according to claim 10 ,

wherein the obtaining code is further configured to cause the at least one processor to obtain the plurality of inputs, including the input, of the at least one of the task and the workflow,

wherein the determining code is further configured to cause the at least one processor to determine whether a state of the at least one of the task and the workflow is set to a running state,

wherein the determining code is further configured to cause the at least one processor to determine whether all of the inputs of the at least one of the task and the workflow observes the lack of data of all of the inputs for the duration equal to the timeout, and

wherein the determining code is further configured to cause the at least one processor to determine, in a case where it is determined that the state is set to the running state, whether to change the state from the running state to an idle state based on whether the at least one of the task and the workflow observes the lack of data of the input for a duration equal to the timeout for all of the inputs.

14. The apparatus according to claim 13 ,

wherein determining whether all of the inputs of the at least one of the task and the workflow observes the lack of data of all of the inputs for the duration equal to the timeout comprises determining whether at least one of the inputs of the at least one of the task and the workflow indicates any of a timeout indication and a complete indication.

15. A non-transitory computer readable medium storing a program causing a computer to execute a process for network based media processing (NBMP), the process comprising:

obtaining an input of at least one of a task and a workflow in NBMP;

setting a timeout for the input of the at least one of the task and the workflow;

determining whether the at least one of the task and the workflow observes a lack of data of the input for a duration equal to the timeout;

determining, in response to determining that the at least one of the task and the workflow observed the lack of data of the input for the duration equal to the timeout, an unavailability of further data of the input;

determining whether each of inputs, including the input, of the at least one of the task and the workflow is to be respectively associated to at least one of inputs and outputs of one or more functions respectively by determining at least ones of an identification and a port name for each of the inputs of the at least one of the task and the workflow and at least ones of a corresponding port name and a stream identification of at least ones of a corresponding input port and output port;

respectively associating, based on determining whether each of the inputs of the at least one of the task and the workflow is to be respectively associated to at least one of inputs and outputs of one or more functions respectively, the inputs of the at least one of the task and the workflow with the at least ones of the inputs and the outputs of the one or more functions;

applying an update to the at least one of the task and the workflow in NBMP based on determining the unavailability of further data of the input; and

processing the at least one of the task and the workflow in NBMP based on the update.