Multi-Region Workflow Management

Patent metadata

Field	Value
Publication number	US-2025370988-A1
Application number	US-202519297323-A
Country	US
Kind code	A1
Filing date	Aug 12, 2025
Priority date	May 15, 2023
Publication date	Dec 4, 2025
Grant date	—

Abstract

Techniques for performing parallel processing jobs across regionally-distributed servers may include executing a requested job in parallel across two or more regional cloud-based servers, the status of parallel jobs may be locally monitored using respective local instances of a status-tracking database. The multiple instances may replicate modifications of one instance of the status database to other instances of the status database to synchronize the status of regional jobs. Replicating modifications across the respective regional instances of the status database facilitates the parallel executing of the jobs across regions while reducing or avoiding unrecoverable delays if the tasks/job hangs or otherwise fails.

First claim

What is claimed is:

1 . A method comprising:
receiving, by a computing device and from a first remote server, a first processing job comprising first data and one or more rules; performing, by the computing device, the first processing job resulting in a processed form of the first data, wherein the performing comprises processing the first data based on the one or more rules; based on a determination that a second remote server has not completed the first processing job:
adding, by the computing device, to a local instance of a status database, an indication that the computing device has completed the first processing job; and
transmitting, by the computing device and to the second remote server, an instruction to terminate the first processing job by adding, to an instance of a status database of the second remote server, the indication.

2 . The method of claim 1 , further comprising:
receiving, by the computing device from the first remote server, a second processing job comprising second data and one or more second validation rules; performing, by the computing device, the second processing job, wherein the performing comprises:
reading the second data;
validating, based on the one or more second validation rules, at least some of the second data;
determining a failure of the performing of the second processing job by the computing device; and writing, by the computing device to the local instance of the status database of the computing device and based on the failure of the performing of the second processing job by the computing device, a second status of the second processing job, wherein the second status indicates the failure of performing the second processing job by the computing device.

3 . The method of claim 1 , further comprising:
receiving, by the computing device from the first remote server, a second processing job comprising a second process identification, second data, one or more second validation rules, and second machine-readable instructions to perform a second process on the second data; performing, by the computing device, the second processing job, wherein the performing comprises:
reading the second data;
validating, based on the one or more second validation rules, at least some of the second data;
determining, by the computing device and from the local instance of the status database of the computing device, whether the second remote server has completed the second processing job; and terminating, by the computing device and based on the determining that the second remote server has completed the second processing job, the performing of the second processing job.

4 . The method of claim 1 , wherein the first processing job is an extraction sub process of an extraction, transform, and load process.

5 . The method of claim 1 , wherein determining the status of the first processing job performed by the second remote server comprises: synchronizing the local instance of the status database of the computing device and a local instance of the status database of the second remote server to determine the status of the first processing job performed by the second remote server.

6 . The method of claim 1 , further comprising executing, by the computing device, a lambda function configured to monitor the status of the first processing job being performed by the computing device and to write the status of the first processing job being performed by the computing device to the local instance of the status database of the computing device.

7 . The method of claim 1 , wherein the first data comprises data from a single data storage.

8 . The method of claim 1 , wherein:
the first data comprises a combination of second data from a first data storage and third data from a second data storage, and a format of the second data corresponds to a format of the third data.

9 . The method of claim 1 , wherein the determination that the second remote server has not completed the first processing job is based on the local instance of the status database of the computing device.

10 . An apparatus comprising:
one or more processors; and memory storing instructions that, when executed by the one or more processors, cause the apparatus to:
receive, by a computing device and from a first remote server, a first processing job comprising first data and one or more rules;
perform, by the computing device, the first processing job resulting in a processed form of the first data by processing the first data based on the one or more rules
based on a determination that a second remote server has not completed the first processing job:
adding, to a local instance of a status database, an indication that the computing device has completed the first processing job; and
transmit, to the second remote server, an instruction to terminate the first processing job by adding, to an instance of a status database of the second remote server, the indication.

11 . The apparatus of claim 10 , wherein the instructions, when executed by the one or more processors, further cause the apparatus to:
receive, by the computing device from the first remote server, a second processing job comprising second data and one or more second validation rules; perform, via the computing device, the second processing job, wherein the instructions to perform further cause the apparatus to:
read the second data; and
validate, based on the one or more second validation rules, at least some of the second data;
determine a failure of the performing of the second processing job by the computing device; and write, by the computing device to the local instance of the status database of the computing device and based on the failure of the performing of the second processing job by the computing device, a second status of the second processing job, wherein the second status indicates the failure of performing the second processing job by the computing device.

12 . The apparatus of claim 10 , wherein the instructions, when executed by the one or more processors, further cause the apparatus to:
receive, by the computing device and from the first remote server, a second processing job comprising a second process identification, second data, one or more second validation rules, and second machine-readable instructions to perform a second process on the second data; and perform, via the computing device, the second processing job, wherein the instructions to perform further cause the apparatus to:
read the second data;
validate, based on the one or more second validation rules, at least some of the second data;
determine, by the computing device and via the local instance of the status database, whether the second remote server has completed the second processing job; and
terminate, by the computing device and based on the determining that the second remote server completed the second processing job, the performing of the second processing job.

13 . The apparatus of claim 10 , wherein the first processing job is an extraction sub process of an extraction, transform, and load process.

14 . The apparatus of claim 13 , wherein the first processing job further comprises a transform sub process of the extraction, transform, and load process.

15 . The apparatus of claim 10 , wherein the instructions, when executed by the one or more processors, further cause the apparatus to determine the status of the first processing job performed by the second remote server by synchronizing the local instance of the status database of the computing device and a local instance of the status database of the s

Assignees

• Capital One Services Llc

Inventors

• Haggerty Timothy
• Nannapaneni Venu Kumar
• Kancharla Ramachandra
• Nair Pravin
• Subhedar Priyank Chittaranjan

Classifications

• G06F16/254

  Extract, transform and load [ETL] procedures, e.g. ETL data flows in data warehouses · CPC title

• G06F16/27

  Replication, distribution or synchronisation of data between databases or within a distributed database system; Distributed database system architectures therefor · CPC title

• G06F16/2365 Primary

  Ensuring data consistency and integrity · CPC title