Consistent modeling and execution of time constructs in business processes

• US 9,304,888 B2
• Filed: 06/25/2013
• Issued: 04/05/2016
• Est. Priority Date: 06/25/2013
• Status: Active Grant

• Current Assignee: Microsoft Technology Licensing LLC (Microsoft Corporation)
• Original Assignee: Microsoft Technology Licensing LLC (Microsoft Corporation)
• Inventors: Wolf, Kenneth David, Brown, Justin David, Pinto, Edmund Samuel Victor, Talbert, Nathan Christopher
• Primary Examiner(s): Lee, Tammy
• Application Number:
  US13/926,372
• Publication Number:
  US 20140380323A1
• Time in Patent Office: 1,015 Days
• Field of Search: None
• US Class Current: 1/1
• CPC Class Codes: G06F 11/34 Recording or statistical evaluation of computer activity, e.g. of down time, of input/output operation ; Recording or statistical evaluation of user activity, e.g. usability assessment
• CPC Class Codes: G06F 9/4843 by program, e.g. task dispatcher, supervisor, operating system
• CPC Class Codes: G06Q 10/06 Resources, workflows, human or project management; Enterprise or organisation planning; Enterprise or organisation modelling

Abstract

Embodiments are directed to executing a workflow using a virtualized clock and to ensuring idempotency and correctness among workflow processes. In one scenario, a computer system a computer system determines that a workflow session has been initialized. The workflow session runs as a set of episodes, where each episode includes one or more pulses of work that are performed when triggered by an event. Each workflow session is processed according to a virtualized clock that keeps a virtual session time for the workflow session. The computer system receives an event that includes an indication of the time the event was generated, and then accesses the received event to determine which pulses of work are to be performed as part of a workflow session episode. The computer system then executes the determined pulses of work according to the virtual session time indicated by the virtualized clock.

Claims

1. A computer system comprising the following:

one or more processors;

system memory; and

one or more computer-readable storage media having stored thereon computer-executable instructions that are executable by the one or more processors to configure the computer system to execute a workflow using a virtualized clock, the computer-executable instructions including instructions that are executable to configure the computer system to perform at least the following;

determine that a workflow session has been initialized, the workflow session including one or more episodes, each episode comprising a pulse of work that is performed when triggered by an event, each workflow session being processed according to a virtualized clock that keeps a virtual session time for the workflow session, wherein receipt of an external message moves the virtualized clock forward if a timestamp on the external message is later than the current workflow session time, while receipt of local messages does not adjust the virtualized clock;

receive an event, the event including an indication of the time the event was generated;

access the received event to determine which one or more pulses of work are to be performed as part of a workflow session episode; and

execute the one or more specified pulses of work according to the virtual session time indicated by the virtualized clock.

2. The computer system of claim 1, wherein business processes executed by the workflow session episodes are deterministic, such that business process inputs have the same outputs, regardless of when the inputs are processed.

3. The computer system of claim 1, wherein each workflow session has its own separate notion of time maintained by that workflow session'"'"'s virtual clock.

4. The computer system of claim 1, the computer-executable instructions also including instructions that are executable to configure the computer system to:

receive an event indicating that a specified action has taken place, the event including a timestamp of the time the event was generated; and

adjust the virtual session time according to the time indicated on the event'"'"'s timestamp.

5. The computer system of claim 1, the computer-executable instructions also including instructions that are executable to configure the computer system to persist one or more portions of data resulting from the specified pulses of work to a data store.

6. The computer system of claim 5, wherein side-processes triggered by the execution of the specified pulses of work are delayed until the data associated with the work pulses has been persisted.

7. The computer system of claim 5, wherein transmission of the data generated by the work pulses is delayed until the data has been persisted.

8. The computer system of claim 1, wherein side-processes triggered by the execution of the specified pulses of work are batched together for batch processing.

9. The computer system of claim 8, wherein the batched, side-processes are delayed until a notation has been recorded in a data store indicating that the batch of side-processes is pending.

10. The computer system of claim 1, wherein workflow sessions are processed as part of an asynchronous business processing runtime.

11. The computer system of claim 1, wherein executing the one or more specified pulses of work according to the updated virtual time indicated by the virtualized clock avoids ghost writing.

12. A method, implemented at a computer system that includes one or more processors, for executing a workflow using a virtualized clock, the method comprising:

determining that a workflow session has been initialized, the workflow session including one or more episodes, each episode comprising a pulse of work that is performed when triggered by an event, each workflow session being processed according to a virtualized clock that keeps a virtual session time for the workflow session;

receiving an event, the event including an indication of the time the event was generated;

accessing the received event to determine which one or more pulses of work are to be performed as part of a workflow session episode; and

executing the one or more specified pulses of work according to the virtual session time indicated by the virtualized clock, wherein side-processes triggered by the execution of the specified pulses of work are batched together for batch processing, and wherein the batched, side-processes are delayed until a notation has been recorded in a data store indicating that the batch of side-processes is pending.

13. The method of claim 12, wherein executing the one or more specified pulses of work according to the updated virtual time indicated by the virtualized clock avoids ghost writing.

14. The method of claim 12, wherein workflow session is executed in a continuation-based runtime.

15. The method of claim 12, wherein the workflow receives as an input at least one of the following:

a queued message, a subscription, a hyper-text transfer protocol (HTTP) response and a database connection response.

16. The method of claim 12, wherein session queries for the current time return the virtual session time, indicating the session'"'"'s notion of time.

17. The method of claim 12, wherein processing of the one or more specified pulses of work is delayed until a specified time.

18. The method of claim 12, wherein processing of the one or more specified pulses of work is delayed for a specified amount of time.

20. The method of claim 12, further comprising:

determining the event generation time from the indication in the event; and

updating the virtual session time for the workflow session to the determined event generation time based on the timestamp included in the event, wherein executing the one or more specified pulses of work according to the virtual session time indicated by the virtualized clock comprises executing the one or more specified pulses of work according to the updated virtual session time indicated by the virtualized clock.

19. A computer system comprising the following:

one or more processors;

system memory; and

one or more computer-readable storage media having stored thereon computer-executable instructions that are executable by the one or more processors to configure the computer system to ensure idempotency among workflow processes, the computer-executable instructions including instructions that are executable to configure the computer system to perform at least the following;

instantiate at least one workflow session, the workflow session including one or more episodes, each episode comprising a pulse of work that is performed when triggered by an event, each workflow session being processed according to a virtualized clock that keeps a virtual time for the workflow session;

determine that at least one of the work pulses has initiated one or more side-process that are to be completed as part of the work pulses;

batch up the one or more side-processes to create a batch of side-processes that are part of the workflow session;

persist the current virtual time and an indication of those side-processes that are part of the batch of side-processes to a data store;

initiate processing of the batch of side-processes; and

persist one or more portions of workflow state to the data store upon determining that the batch of side-processes has completed processing, such that the workflow session'"'"'s clock value is durably updated at the time of persistence of the one or more portions of workflow state.