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.
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 & computingMore from Amazon in AI & software
- Amazon patents system that cites sources for AI answers Sep 29, 2026
- Amazon patents tech to swap words in movies using actor's voice Sep 8, 2026
- Amazon patents ML tool to add graphics to live sports from moving cameras Sep 15, 2026
- Amazon patents shopping assistant that remembers your search filters Oct 6, 2026
- Amazon patents system where AI agents split tasks and talk to each other Oct 20, 2026
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.