Scalable workflow processing

Patent metadata

Field	Value
Publication number	US-10748098-B2
Application number	US-201916673409-A
Country	US
Kind code	B2
Filing date	Nov 4, 2019
Priority date	Oct 20, 2008
Publication date	Aug 18, 2020
Grant date	Aug 18, 2020

Abstract

Disclosed are various embodiments for scalable workflow processing. In one embodiment, a plurality of decision applications each embody a functional expression of a corresponding one of a plurality of workflow definitions. Each of the plurality of decision applications is configured to be repeatedly instantiated. A workflow execution application is configured to orchestrate an execution of each one of a plurality of workflow instances. The workflow execution application is in data communication with each instance of a respective one of the plurality of decision applications. Each of the plurality of decision applications is configured to determine a next action to be taken for respective ones of the plurality of workflow instances.

First claim

Therefore, the following is claimed:

1. A system, comprising:
at least one processor-based system comprising a processor and a memory;
a plurality of decision applications executable in the at least one processor-based system, each of the plurality of decision applications embodying a functional expression of one of a corresponding one of a plurality of workflow definitions, wherein each of the plurality of decision applications is configured to be repeatedly instantiated in the at least one processor-based system;
a workflow execution application executable in the at least one processor-based system, the workflow execution application being configured to orchestrate an execution of each one of a plurality of workflow instances;
the workflow execution application being in data communication with each one of the decision applications, wherein each of the plurality of decision applications is configured to determine a next action to be taken for respective ones of the plurality of workflow instances;
the decision applications being configured to poll the workflow execution application for a workflow instance that requires a determination of the next action; and
the workflow execution application being configured to apply a workflow history associated with a respective workflow instance to one of the plurality of decision applications in response to the poll to facilitate a determination as to the next action to be taken in the workflow instance by the one of the plurality of decision applications.

2. The system of claim 1 , further comprising a plurality of queues accessible to the processor-based system, wherein the plurality of workflow instances are stored in the plurality of queues to await application to respective ones of the plurality of decision applications to determine the next action to be taken for the plurality of workflow instances.

3. The system of claim 2 , wherein each of the plurality of queues and each of the plurality of decision applications is associated with one of a plurality of workflow types, where the workflow instances listed in a given one of the plurality of queues associated with a given one of the plurality of workflow types are applied to a corresponding one of the plurality of decision applications associated with the given one of the plurality of workflow types.

4. The system of claim 1 , wherein each of the plurality of decision applications is configured to determine the next action to be taken for respective ones of the plurality of workflow instances based at least in part on a corresponding workflow history of the respective ones of the plurality of workflow instances.

5. A system, comprising:
at least one processor-based system comprising a processor and a memory;
a plurality of decision applications executable in the at least one processor-based system, each decision application embodying a functional expression of a corresponding one of a plurality of workflow definitions, wherein each of the plurality of decision applications is configured to be repeatedly instantiated in the at least one processor-based system;
a workflow execution application executable in the at least one processor-based system, the workflow execution application being configured to orchestrate an execution of each one of a plurality of workflow instances; and
the workflow execution application being in data communication with each instance of a respective one of the plurality of decision applications, wherein each of the plurality of decision applications is configured to determine a next action to be taken for respective ones of the plurality of workflow instances.

6. The system of claim 5 , wherein the plurality of decision applications are configured to poll the workflow execution application for a workflow instance that requires a determination of the next action.

7. The system of claim 6 , wherein the workflow execution application applies a workflow history associated with a workflow instance to one of the plurality of decision applications in response to the poll to facilitate the determination as to the next action to be taken in the workflow instance by the one of the plurality of decision applications.

8. The system of claim 5 , further comprising a plurality of queues accessible to the processor-based system, wherein the workflow instances are stored in the plurality of queues to await application to respective ones of the plurality of decision applications to determine the next action to be taken for the plurality of workflow instances.

9. The system of claim 8 , wherein each of the plurality of queues and each of the plurality of decision applications are associated with one of a plurality of workflow types, where the plurality of workflow instances listed in a given one of the plurality of queues associated with a given one of the plurality of workflow types are applied to a corresponding one of the plurality of decision applications associated with the given one of the plurality of workflow types.

10. The system of claim 5 , wherein a functional expression of one of the plurality of workflow definitions embodied in a respective one of the plurality of decision applications is compatible with a predefined type of workflow instance.

11. The system of claim 5 , wherein each of the plurality of decision applications is configured to determine the next action to be taken for respective ones of the plurality of workflow instances based at least in part on a corresponding workflow history of the respective ones of the plurality of workflow instances.

12. The system of claim 11 , wherein the workflow execution application is further configured to track an application of the corresponding workflow history to the respective ones of the plurality of workflow instances to prevent duplicate processing of the corresponding workflow history.

13. The system of claim 5 , further comprising a firewall imposed between the plurality of decision applications and the workflow execution application.

14. A non-transitory computer-readable medium storing instructions executable by at least one processor-based system comprising a processor and a memory, the instructions comprising:
a plurality of decision applications, each decision application embodying a functional expression of a corresponding one of a plurality of workflow definitions, wherein each of the plurality of decision applications is configured to be repeatedly instantiated;
a workflow execution application configured to orchestrate an execution of each one of a plurality of workflow instances; and
the workflow execution application being in data communication with each instance of a respective one of the plurality of decision applications, wherein each of the plurality of decision applications is configured to determine a next action to be taken for respective ones of the plurality of workflow instances.

15. The non-transitory computer-readable medium of claim 14 , wherein the plurality of decision applications are configured to poll the workflow execution application for a workflow instance that requires a determination of the next action.

16. The non-transitory computer-readable medium of claim 15 , wherein the workflow execution application applies a workflow history associated with a workflow instance to one of the plurality of decision applications in response to the poll to facilitate the determination as to the next action to be taken in the workflow instance by the one of the plurality of decision applications.

17. The non-transitory computer-readable medium of claim 14 , further comprising a plurality of

Assignees

• Amazon Tech Inc

Inventors

• Robbins Alan Stuart
• Satyanarayana Srikanth
• Sears Richard M

Classifications

• G06F21/602

  Providing cryptographic facilities or services · CPC title

• G06Q10/06316 Primary

  Sequencing of tasks or work · CPC title

• G06F16/9535

  Search customisation based on user profiles and personalisation · CPC title

• G06N20/00

  Machine learning · CPC title