SYSTEMS AND METHODS FOR PROVIDING SERVICES IN A STATELESS APPLICATION FRAMEWORK

• US 20190332433A1
• Filed: 04/27/2018
• Published: 10/31/2019
• Est. Priority Date: 04/27/2018
• Status: Active Grant

• Current Assignee: PayPal, Inc. (PayPal Holdings, Inc.)
• Original Assignee: PayPal, Inc. (PayPal Holdings, Inc.)
• Inventors: Nadimpalli, Venkata Ramana Varma, Shvid, Alexander Y., Pobbathi, Vahini, Hennig, Karl Anton
• Granted Patent: US 10,733,018 B2
• Time in Patent Office: Days
• CPC Class Codes: G06F 16/903 Querying for retrieval from the web G06F16/953
• CPC Class Codes: G06F 9/50 Allocation of resources, e.g. of the central processing unit [CPU]
• CPC Class Codes: G06F 9/5038 considering the execution order of a plurality of tasks, e.g. taking priority or time dependency constraints into consideration scheduling strategies G06F9/4881 and subgroups

Abstract

Methods and systems for providing an external scheduler in a stateless application framework are presented. A first instance of a stateless application transmits a job request to a data processing engine, and submits a message to a messaging queue. The message indicates a task to be performed according to a delayed schedule. The first instance of the stateless application terminates after submitting the message. The messaging queue transmits the message to the stateless application framework according to the delayed schedule. Upon receiving the message, a second instance of the stateless application is instantiated. The second instance of the stateless application performs an action based on the message and terminates.

Claims

1. A method comprising:

obtaining, by a first instance of a stateless application executed on a computer system, a workflow associated with a user account, wherein the workflow indicates a first task and a second task, wherein the second task is associated with a delayed schedule;

transmitting, by the first instance of the stateless application, a job request to a data processing engine based on the first task indicated in the workflow;

submitting, by the first instance of the stateless application to a messaging module, a message self-addressed to the stateless application based on the workflow, wherein the self-addressed message comprises a reference to the user account and the second task;

in response to receiving the self-addressed message from the messaging module, instantiating, by the computer system, a second instance of the stateless application; and

performing, by the second instance of the stateless application, the second task based on the self-addressed message.

2. The method of claim 1, wherein the second task comprises a job status inquiry associated with the job request, wherein performing the action comprises transmitting a job status inquiry request to the data processing engine.

3. The method of claim 1, further comprising receiving, from a second data processing engine, an indication of an event associated with the user account, wherein the transmitting of the job request is responsive to receiving the indication.

4. The method of claim 3, further comprising in response to receiving the indication, accessing, by the first instance of the stateless application, a context database to create a record for the event, wherein the record comprises state data indicating a context of the user account within a state machine configuration.

5. The method of claim 4, wherein the second task comprises a state inquiry associated with the user account, wherein performing the action comprises:

accessing, by the second instance of the stateless application, the context database to retrieve the state data from the record; and

transmitting the state data to the second data processing engine.

6. The method of claim 4, further comprising:

in response to receiving a response from the data processing engine, instantiating, by the computer system, a third instance of the stateless application; and

accessing, by the third instance of the stateless application, the context database to update the context of the user account by inserting second context data to the record based on the response.

7. The method of claim 4, wherein the self-addressed message comprises a session identifier that identifies the user account, the event, and the state machine configuration.

8. The method of claim 7, wherein the indication comprises an account identifier associated with the user account and an event identifier associated with the event, wherein the method further comprising:

selecting, from a plurality of state machine configurations, the state machine configuration corresponding to the event; and

generating the session identifier based on the user identifier, the event identifier, and a configuration identifier associated with the state machine configuration.

9. The method of claim 1, wherein the delayed schedule comprises a frequency.

10. The method of claim 1, wherein the context database and the messaging module are external to the stateless application.

11. The method of claim 1, further comprising terminating the first instance of the stateless application after submitting the self-addressed message to the messaging module.

12. A system, comprising:

a non-transitory memory; and

one or more hardware processors coupled with the non-transitory memory and configured to read instructions from the non-transitory memory to cause the system to perform operations comprising;

obtaining, by a first instance of a stateless application executed on a computer system, a workflow associated with a user account, wherein the workflow indicates a first task and a second task, wherein the second task is associated with a delayed time;

transmitting, by the first instance of the stateless application, a job request to a data processing engine based on the first task indicated in the workflow;

submitting, by the first instance of the stateless application to a messaging module, a first message addressed to the stateless application based on the workflow, wherein the first message comprises a reference to the user account and the second task;

in response to receiving the first message from the messaging module, instantiating, by the computer system, a second instance of the stateless application; and

performing, by the second instance of the stateless application, the second task based on the first message.

13. The system of claim 12, wherein the messaging module comprises a queue having a plurality of messages.

14. The system of claim 13, wherein the operations further comprise inserting, by the messaging module, the first message in the queue based on the delayed time associated with the second task.

15. The system of claim 14, wherein the operations further comprise transmitting, by the messaging module, the first message to the stateless application according to the delayed time.

16. The system of claim 12, wherein the second task comprises a job status inquiry associated with the job request, wherein performing the action comprises transmitting a job status inquiry request to the data processing engine.

17. The system of claim 12, wherein the second task comprises a status inquiry associated with the user account, wherein performing the action comprises:

retrieving, by the second instance of the stateless application, status data indicating a current status of the user account within the workflow; and

transmitting, by the second instance of the stateless application, the status data to a second data processing engine.

18. The system of claim 12, wherein the operations further comprise terminating the first instance of the stateless application after submitting the first message to the messaging module.

19. A non-transitory machine readable medium having stored thereon machine-readable instructions executable to cause a machine to perform operations comprising:

obtaining, by a stateless application executed on a computer system, a workflow associated with a user account, wherein the workflow indicates a first task and a second task, wherein the second task is associated with a delayed time;

transmitting, by the stateless application, a job request to a data processing engine based on the first task indicated in the workflow;

submitting, by the stateless application to a messaging queue, a first message addressed to the stateless application based on the workflow, wherein the first message comprises a reference to the user account and the second task; and

in response to receiving the first message from the messaging queue, performing, by the stateless application, the second task based on the first message.

20. The non-transitory machine readable medium of claim 19, wherein the messaging queue is external to the stateless application.