CPC G06F 9/4881 (2013.01) [G05B 15/02 (2013.01); G06F 8/433 (2013.01); G06F 9/3838 (2013.01); G06F 9/4494 (2018.02); G06F 9/451 (2018.02); G06F 9/5072 (2013.01); G06F 2209/486 (2013.01)] | 16 Claims |
1. A computerized method, performed by a computing system having one or more hardware computer processors and one or more non-transitory computer readable storage device storing software instructions executable by the computing system to perform the computerized method comprising:
accessing a data processing pipeline specification, wherein the data processing pipeline specification defines a plurality of data elements of a data processing pipeline;
identifying from the data processing pipeline specification a task indicating a defined relationship between a first data element and a second data element, wherein the task is associated with metadata indicating an expected language or transformation, an expected dependency, or an expected row and/or column name;
determining, for the task, one or more data processing elements intended to receive the first data element and to produce the second data element; and
verifying that the one or more data processing elements receive the first data element and produce the second data element according to the defined relationship.
|