CPC G06F 16/2365 (2019.01) [G06F 16/215 (2019.01)] | 20 Claims |
1. A method comprising:
ingesting, through a data ingestion pipeline, a plurality of content elements from a source to a destination, the ingestion pipeline comprising a plurality of nodes between the source and the destination;
detecting, by a data management system, a gap in the ingestion pipeline, the gap indicating a difference associated with a content element of the plurality of content elements between a first node and a second node of the ingestion pipeline;
in response to detecting the gap, determining whether the content element is found at the second node;
based on the content element being found at the second node, determining whether an issue is a system-based issue or a single issue; and
automatically triggering, by the data management system, reingesting of the content element from the first node based on the issue being the single issue or in response to a repair performed on a component or machine associated with the ingestion pipeline based on the system-based issue.
|