/Patent Tracker
AmazonGranted patentAI & softwareInterest 4/10

Amazon patents system that auto-updates live data pipelines when code changes

This patent describes a cloud system that automatically updates running data processing workflows when developers change the underlying code. It checks if the changes are safe, tests them against specific rules, and then deploys the update so new data is processed immediately without stopping the service.

Why it mattersThis improves how companies manage large amounts of data by reducing manual work and errors when updating their internal data systems.

In the filing’s own words

Provided is a system for facilitating continuous integration and continuous deployment of data warehousing workflows in a cloud network environment. A workflow integration and deployment service may communicate with a code repository service to be notified of code changes, obtain code changes, generate updated workflows, test updated workflows, and deploy updated workflows. The workflow integration and deployment service may maintain workflow generation and testing rules to generate, test, and deploy workflows according to user preferences.

What exactly they claim (claim 1)

1. A cloud provider system comprising: one or more processors; a code repository service, executed by the one or more processors, storing a plurality of user tasks, wherein each task of the plurality of user tasks when executed by the one or more processors is configured to perform an operation as part of an extract, transform, and load (ETL) workflow for extracting data from one or more data sources, transforming the data, and loading the transformed data onto one or more destinations; and a workflow integration and deployment service comprising a workflow manager with one or more workflow testing rules and in network communication with the code repository service, wherein the workflow integration and deployment service when executed by the one or more processors is configured to at least: receive, from the code repository service, an indication that a code change has been made to a task associated with a user account; determine that the task is part of a live ETL workflow that has been deployed based on the ETL workflow on a first set of computing resources assigned to the user account and configured to receive input data from a source associated with the user account, transform the input data, and output the transformed input data to a destination associated with the user account; determine that the code change made to the task is to be propagated to the live ETL workflow such that any additional data subsequently received by the live ETL workflow is transformed according to the code change made to the task; identify a set of dependencies associated with the task based at least in part on the code change made to the task, wherein the set of dependencies associated with the task includes code dependency information usable to determine a position of the task within an updated ETL workflow, and wherein the set of dependencies includes at least time dependency information usable to determine a time or time range at which the task is to be executed and cluster dependency information usable to determine a cluster of compute capacity in which the task is to be executed; generate, using the workflow manager and based on the code dependency information, the time dependency information, and the cluster dependency information, the updated ETL workflow that includes the code change made to the task and satisfies the set of dependencies associated with the task; test, using the workflow manager, the updated ETL workflow according to the one or more workflow testing rules associated with the user account to lower error rates; update and deploy the live ETL workflow according to the updated ETL workflow based on the testing; and automatically execute the updated live ETL workflow to cause the updated live ETL workflow to receive additional input data from the source, transform the additional input data according to the code change made to the task, and output the transformed additional input data to the destination.

Facts

Company
Amazon (Amazon Technologies, Inc.)
Official title
Continuous integration and updating a live extract, transform, and load (ETL) workflow based on determined code change
Patent number
US12743325B1
Application number
17456859
Filed
Nov 29, 2021
Granted
Sep 22, 2026
Inventors
4
Claims
20

Classified under

G06F 9/52 Physics & computingG06F 16/254 Physics & computingG06F 8/433 Physics & computingG06F 9/5038 Physics & computing

More from Amazon in AI & software

Summaries are simplified from the filing’s own abstract and first claim. A patent filing is not a product announcement.
Patent data and drawings: U.S. Patent and Trademark Office (USPTO). Nebula is not affiliated with or endorsed by the USPTO.