# US 12,225,049 B2 · System and methods for integrating datasets and automating transformation workflows using a distributed computational graph

> Agents: this data is available as JSON from the patentgrep API and MCP server — see https://patentgrep.com/llms.txt

- Number: US 12,225,049 B2
- Document ID: US12225049B2
- Status: Granted
- Kind: B2
- Application number: 17/185,655
- Filed: 2021-02-25
- Published: 2021-12-09
- Granted: 2025-02-11
- Earliest claimed: 2015-10-28
- Assignees: Qomplx LLC
- Applicants: Qomplx LLC
- Inventors: Jason Crabtree; Luka Jurukovski; Bhashit Parikh; Angadbir Salaria; Andrew Sellers
- Web page: https://patentgrep.com/patent/US12225049B2

## CPC

- G06F 21/577: {Assessing vulnerabilities and evaluating computer system security}
- H04L 63/20: {for managing network security; network security policies in general (filtering policies H04L63/0227)}
- 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)}
- G06F 16/2477: {Temporal data queries}
- G06F 16/951: Indexing; Web crawling techniques
- H04L 63/1425: {Traffic logging, e.g. anomaly detection}
- H04L 63/1433: {Vulnerability analysis}
- H04L 63/1441: {Countermeasures against malicious traffic (countermeasures against attacks on cryptographic mechanisms H04L9/002)}
- H04L 67/10: in which an application is distributed across nodes in the network (software deployment G06F8/60; multiprogramming arrangements G06F9/46)
- G06F 9/4881: {Scheduling strategies for dispatcher, e.g. round robin, multi-level priority queues}
- G06F 9/54: Interprogram communication
- G06F: ELECTRIC DIGITAL DATA PROCESSING (computer systems based on specific computational models G06N)
- H04L: TRANSMISSION OF DIGITAL INFORMATION, e.g. TELEGRAPHIC COMMUNICATION (arrangements common to telegraphic and telephonic communication H04M)

## Abstract

A system and methods for integrating datasets and automating transformation workflows using a distributed computational graph comprising modules that represent various stages within a data processing workflow. The system detects new datasets and automatically selects or assembles a workflow to process the new data, and integrates new data through a series of identification, transformation, and metadata enrichment pipelines.

## Claims

### Claim 1

A system for integrating new datasets and automating transformation workflows using a distributed computational graph, comprising:
a computing device comprising a memory, a processor, and a non-volatile data storage device;
a front end comprising a first plurality of programming instructions stored in the memory of, and operating on the processor of, the computing device, wherein the first plurality of programming instructions, when operating on the processor, cause the computing device to:
provide a graphical user interface for creation of a distributed computational graph representing a data processing workflow, wherein:
the graphical user interface comprises icons representing data processing modules and connections between the modules;
the distributed computational graph comprises one or more of the data processing modules represented as nodes of the distributed computational graph and connections between the data processing modules represented as edges of the distributed computational graph; and
one or more of the nodes of the distributed computational graph is a data processing module that contains code for accessing an application programing interface (API) of a cloud-based data processing service;
and send the distributed computational graph to a system back end for implementation of the data processing workflow; and
a system back end comprising a second plurality of programming instructions stored in the memory of, and operating on the processor of, the computing device, wherein the second plurality of programming instructions, when operating on the processor, cause the computing device to:
receive the distributed computational graph;
detect changes to a data store;
construct the data processing workflow from the distributed computational graph using the application programing interface that generates workflow code via representational state transfer calls;
instantiate and validate the data processing workflow using the workflow code;
prepare the data processing workflow for processing by initializing one or more of: software components, devices, cloud-based services;
serialize the data processing workflow as a series of processing events; and
execute the processing events using a data processing engine.