Data pipeline to execute convergence based agricultural actions

A method of convergence based agricultural actions via a data pipeline, comprising:

• receiving, by a data processing system comprising one or more processors coupled with memory, for storage in a buffer, raw data from a plurality of data feeds that are indicative of performance of agriculture on a farm;
• tagging, by the data processing system prior to execution of a data translation process, the raw data with a plurality of identifiers;
• executing, by the data processing system with the raw data maintained in the buffer, the data translation process to map the raw data from a first one or more shapes into a second shape to generate a normalized data set;
• detecting, by the data processing system, an error in a portion of the normalized data set;
• determining, by the data processing system responsive to detection of the error, an identifier of the plurality of identifiers tagged to a portion of the raw data in the buffer that corresponds to the portion of the normalized data set with the error;
• and
• updating, by the data processing system via a second data translation process on the portion of the raw data in the buffer that corresponds to the portion of the normalized data set with the error, the normalized data set to remove the error.

A non-transitory computer readable medium storing processor executable instructions for convergence based agricultural actions via a data pipeline that, when executed by one or more processors, cause the one or more processors to:

• receive, for storage in a buffer, raw data from a plurality of data feeds that are indicative of performance of agriculture on a farm;
• tag, prior to execution of a data translation process, the raw data with a plurality of identifiers;
• execute, with the raw data maintained in the buffer, the data translation process to map the raw data from a first one or more shapes into a second shape to generate a normalized data set;
• detect an error in a portion of the normalized data set;
• determine, responsive to detection of the error, an identifier of the plurality of identifiers tagged to a portion of the raw data in the buffer that corresponds to the portion of the normalized data set with the error;
• and
• update, via a second data translation process on the portion of the raw data in the buffer that corresponds to the portion of the normalized data set with the error, the normalized data set to remove the error.