Distributed order orchestration system with rollback checkpoints for adjusting long running order management fulfillment processes

• US 10,061,464 B2
• Filed: 03/05/2010
• Issued: 08/28/2018
• Est. Priority Date: 03/05/2010
• Status: Active Grant

• Current Assignee: Oracle International Corporation (Oracle Corporation)
• Original Assignee: Oracle International Corporation (Oracle Corporation)
• Inventors: Addala, Raju, Singh, Alok, Reed, Leah, Iyengar, Balaji, Mudumba, Siddhardha, Suman, Kolanupaka
• Primary Examiner(s): Rudy, Andrew Joseph
• Application Number:
  US12/718,501
• Publication Number:
  US 20110219218A1
• Time in Patent Office: 3,098 Days
• Field of Search: 705 22, 705 28, 705 20, 705 261, 705 272
• CPC Class Codes: G06F 11/1438 Restarting or rejuvenating
• CPC Class Codes: G06F 3/048 Interaction techniques based on graphical user interfaces [GUI]

Abstract

A computer-readable medium, computer-implemented method, and system are provided. In one embodiment, a rollback checkpoint for a step in an executable process is established, and the executable process is executed. A change request is received, and the step with the established rollback checkpoint is adjusted. Any subsequent steps of the executable process are also adjusted.

Claims

1. A non-transitory computer-readable medium having instructions stored thereon that, when executed by a an internal processor of a distributed computing system that includes at least the internal processor and one or more external processors, cause the internal processor to perform a method in the distributed computing system, the method comprising:

defining a graphical user interface configured to receive input and provide the received input to the internal processor;

receiving an input through the graphical user interface defining an end result of the computer-implemented method;

decomposing the end result entered through the graphical user interface into a distributed orchestration process that includes a plurality of executable steps to be executed in an ordered sequence by the one or more external processors of the distributed computing system;

establishing, by the internal processor, a plurality of rollback checkpoints for the plurality of executable steps in the distributed orchestration process;

selecting a rollback checkpoint from the plurality of rollback checkpoints, wherein the selecting the rollback checkpoint further includes

selecting a most recent rollback checkpoint where there are no steps that modify one or more data attributes between the most recent rollback checkpoint and an immediate subsequent rollback checkpoint and where the most recent rollback checkpoint is before a first step that requires an adjustment of a result of an executable step of the plurality of executable steps when a change request is received through the graphical user interface;

executing the distributed orchestration process by sequentially executing the plurality of the executable steps;

receiving the change request through the graphical user interface, wherein the change request comprises a modification to at least one of the plurality of executable steps in the distributed orchestration process;

creating a cancel executable service and a re-perform executable service based on a cancel/re-perform compensation pattern defined for a step with the selected rollback checkpoint, wherein the cancel/re-perform compensation pattern comprises a template for the cancel service and the re-perform service defining executable steps to be included in the cancel service and the re-perform service;

wherein the cancel executable service invokes a first external processor to cancel a task previously invoked by the step by sending a cancel message to the first external processor and receiving a cancel result message from the first external processor; and

wherein the re-perform service invokes a second external processor to perform the task previously invoked by the step with a current set of data associated with the modification by sending a perform message to the second external processor and receiving a perform result message from the second external processor;

cancelling the step with the selected rollback checkpoint using the created cancel service and re-performing the step using the created re-perform service based on the modification; and

cancelling any subsequent steps of the executable orchestration process and re-performing the subsequent steps based on the modification.

2. The non-transitory computer-readable medium of claim 1, wherein the selecting the rollback checkpoint further comprises an option of selecting the rollback checkpoint based on a selection of a user, and wherein the rollback checkpoint is selected based on the selection of the user.

3. The non-transitory computer-readable medium of claim 2, wherein the most recent rollback checkpoint is selected.

4. The non-transitory computer-readable medium of claim 1, wherein the cancel/re-perform compensation pattern further comprises a compensation sequence, wherein the compensation sequence causes the re-performing of the subsequent steps based on the modification to be performed in a different order than what was originally performed in the executable orchestration process.

5. The non-transitory computer-readable medium of claim 1, wherein the selection of the rollback checkpoint is implemented by a deterministic algorithm.

6. The non-transitory computer-readable medium of claim 2, wherein the selection of the user is captured via a user interface.

7. A computer-implemented method in a distributed computing system that includes at least an internal processor and one or more external processors, the computer-implemented method comprising:

providing a graphical user interface configured to receive input and provide the received input to the internal processor;

receiving an input through the graphical user interface defining an end result of the computer-implemented method;

decomposing the end result entered through the graphical user interface into a distributed orchestration process that includes a plurality of executable steps to be executed in an ordered sequence by the one or more external processors of the distributed computing system;

establishing, by the internal processor, a plurality of rollback checkpoints for the plurality of executable steps in the distributed orchestration process;

selecting a rollback checkpoint from the plurality of rollback checkpoints, wherein the selecting the rollback checkpoint further includes

selecting a most recent rollback checkpoint where there are no steps that modify one or more data attributes between the most recent rollback checkpoint and an immediate subsequent rollback checkpoint and where the most recent rollback checkpoint is before a first step that requires an adjustment of a result of an executable step of the plurality of executable steps when a change request is received through the graphical user interface;

executing the distributed orchestration process by sequentially executing the plurality of the executable steps;

receiving the change request through the graphical user interface, wherein the change request comprises a modification to at least one of the plurality of executable steps in the distributed orchestration process;

creating a cancel executable service and a re-perform executable service based on a cancel/re-perform compensation pattern defined for a step with the selected rollback checkpoint, wherein the cancel/re-perform compensation pattern comprises a template for the cancel service and the re-perform service defining executable steps to be included in the cancel service and the re-perform service;

wherein the cancel executable service invokes a first external processor to cancel a task previously invoked by the step by sending a cancel message to the first external processor and receiving a cancel result message from the first external processor; and

wherein the re-perform service invokes a second external processor to perform the task previously invoked by the step with a current set of data associated with the modification by sending a perform message to the second external processor and receiving a perform result message from the second external processor;

cancelling the step with the selected rollback checkpoint using the created cancel service and re-performing the step using the created re-perform service based on the modification; and

cancelling any subsequent steps of the executable orchestration process and re-performing the subsequent steps based on the modification.

8. The computer-implemented method of claim 7, wherein the selecting the rollback checkpoint further comprises an option of selecting the rollback checkpoint based on a selection of a user, and wherein the rollback checkpoint is selected based on the selection of the user.

9. The computer-implemented method of claim 8, wherein the most recent rollback checkpoint is selected.

10. The computer-implemented method of claim 7, wherein the cancel/re-perform compensation pattern further comprises a compensation sequence, wherein the compensation sequence causes the re-performing of the subsequent steps based on the modification to be performed in a different process than what was originally performed in the executable orchestration process.

11. The computer-implemented method of claim 7, wherein the selection of the rollback checkpoint is implemented by a deterministic algorithm.

12. The computer-implemented method of claim 8, wherein the selection of the user is captured via the graphical user interface.

13. A distributed computing system, comprising:

an internal processor;

one or more external processors;

a graphical user interface configured to receive input and provide the received input to the internal processor, wherein the graphical user interface receives an input defining an end result of the orchestration system;

a decomposition module configured to decompose the end result entered through the graphical user interface into a distributed orchestration process that includes a plurality of executable steps to be executed in an ordered sequence by the one or more external processors of the distributed computing system; and

an orchestration module executed by the internal processor and configured to establish a plurality of rollback checkpoints for the plurality of executable steps in the distributed orchestration process;

wherein the orchestration module is further configured to select a rollback checkpoint from the plurality of rollback checkpoints, wherein the selecting the rollback checkpoint further comprises selecting a most recent rollback checkpoint where there are no steps that modify one or more data attributes between the most recent rollback checkpoint and an immediate subsequent rollback checkpoint and where the most recent rollback checkpoint is before a first step that requires an adjustment of a result of an executable step of the plurality of executable steps when a change request is received through the graphical user interface;

wherein the orchestration module is further configured to execute the distributed orchestration process by sequentially executing the plurality of the executable steps;

wherein the orchestration module is further configured to receive the change request through the graphical user interface, wherein the change request comprises a modification to at least one of the plurality of executable steps in the distributed orchestration process;

wherein the orchestration module is further configured to create a cancel executable service and a re-perform executable service based on a cancel/re-perform compensation pattern defined for a step with the selected rollback checkpoint, wherein the cancel/re-perform compensation pattern comprises a template for the cancel service and the re-perform service defining executable steps to be included in the cancel service and the re-perform service;

wherein the executable cancel service invokes a first external processor to cancel a task previously invoked by the step by sending a cancel message to the first external processor and receiving a cancel result message from the first external processor; and

wherein the re-perform service invokes a second external processor to perform the task previously invoked by the step with a current set of data associated with the modification by sending a perform message to the second external processor and receiving a perform result message from the second external processor;

wherein the orchestration module is further configured to cancel the step with the selected rollback checkpoint using the created cancel service and re-perform the step based on the modification using the created re-perform service; and

wherein the orchestration module is further configured to cancel any subsequent steps of the executable orchestration process and re-perform the subsequent steps based on the modification.

14. The orchestration system of claim 13, wherein the selecting the rollback checkpoint further comprises an option of selecting the rollback checkpoint based on a selection of a user, and wherein the rollback checkpoint is selected based on the selection of the user.

15. The orchestration system of claim 14, wherein the most recent rollback checkpoint is selected.

16. The orchestration system of claim 13, wherein the cancel/re-perform compensation pattern further comprises a compensation sequence, wherein the compensation sequence causes the re-performing of the subsequent steps based on the modification to be performed in a different order than what was originally performed in the executable orchestration process.

17. The orchestration system of claim 13, wherein the selection of the rollback checkpoint is implemented by a deterministic algorithm.

18. The orchestration system of claim 14, wherein the selection of the user is captured via a user interface.