Methods, systems, and computer program products for asynchronous resumption of a dataflow

摘要

A method, system, and computer program product for providing asynchronous resumption of a dataflow are provided. The method includes building an executable directed graph from a dataflow that includes multiple interconnected nodes, where at least one of the interconnected nodes is an asynchronous node. The method further includes creating an event flow that includes the asynchronous node and interconnections subsequent to the asynchronous node. The method also includes invoking execution of the executable directed graph, and creating a state object with an identifier associated with the event flow in response to reaching the asynchronous node. The method additionally includes continuing execution of the executable directed graph while avoiding the asynchronous node and the interconnections subsequent to the asynchronous node, and resuming execution of the event flow as identified via the state object upon receiving a response for the asynchronous node.

主权项

1. A method for providing asynchronous resumption of a dataflow, comprising:
building an executable directed graph from a dataflow comprising multiple interconnected nodes, wherein at least one of the interconnected nodes is an asynchronous node, wherein at least one synchronous node is dependent upon execution of the asynchronous node and wherein at least one synchronous node is subsequent to and not dependent upon the asynchronous node; creating an event flow from the executable directed graph, the event flow comprising the asynchronous node and interconnections subsequent to the asynchronous node including the at least one synchronous node dependent upon execution of the asynchronous node; invoking execution of the executable directed graph; creating a state object with an identifier associated with the event flow in response to reaching the asynchronous node; continuing execution of the executable directed graph while avoiding the asynchronous node and the interconnections subsequent to and dependent upon the asynchronous node, wherein continuing execution of the executable directed graph includes executing the at least one synchronous node is subsequent to and not dependent upon the asynchronous node; and resuming execution of the event flow as identified via the state object upon receiving a response for the asynchronous node.