Re-execution of an analytical process based on lineage metadata
AssigneeHewlett Packard Enterprise Development LP
InventorsDouglas L. Voigt, Suparna Bhattacharya, Neeraj Gokhale
Life of this patent
Estimating the term…
Abstract
Examples disclosed herein relate to re-execution of an analytical process based on lineage metadata. In an example, a determination may be made on a hub device that an analytical process previously executed on a remote edge device is to be re-executed on the hub device, wherein the analytical process is part of an analytical workflow that is implemented at least in part on the hub device and the remote edge device. In response to the determination, a storage location of input data for re-executing the analytical process may be identified based on lineage metadata stored on the hub device, and input data may be acquired from the storage location.
Claims15
A method comprising:
- determining, on a hub device, that an analytical process previously executed on a remote edge device is to be re-executed on the hub device, wherein the analytical process is part of an analytical workflow that is implemented on the hub device and the remote edge device;
- in response to the determination, identifying, based on lineage metadata stored on the hub device, a storage location of input data for re-executing the analytical process, wherein the lineage metadata comprises data associated with input data provided to the analytical process, data associated with output data generated by the analytical process, and data identifying the analytical process used to process the input data to generate the output data;
- and
- acquiring, on the hub device, the input data from the storage location;
- wherein determining that the analytical process is to be re-executed comprises determining a number of times the analytical process failed to be executed on the hub device, and a number of times a request for the input data is unfulfilled by the remote edge device, due to unavailability of the input data from the remote edge device.
A device comprising:
- one or more hardware processors;
- and
- a determination engine, executing on the one or more hardware processors, to determine that an analytical process previously executed on a remote edge device is to be re-executed on the device, wherein the analytical process is part of an analytical workflow that is implemented on the device and the remote edge device;
- an identification engine, executing on the one or more hardware processors, to, in response to the determination, identify based on lineage metadata stored on the device, a storage location of input data to re-execute the analytical process, wherein the lineage metadata comprises data associated with input data provided to the analytical process, data associated with output data generated by the analytical process, and data identifying the analytical process used to process the input data to generate the output data;
- and
- an acquisition engine, executing on the one or more hardware processors, to acquire the input data from the storage location;
- wherein determine that the analytical process is to be re-executed comprises determine a number of times the analytical process failed to be executed on the hub device, and a number of times a request for the input data is unfulfilled by the remote edge device, due to unavailability of the input data from the remote edge device.
A non-transitory machine-readable storage medium comprising instructions, the instructions executable by a processor to:
- determine, on a hub device, that an analytical process previously executed on a remote edge device is to be re-executed on the hub device, wherein the analytical process is part of an analytical workflow that is implemented on the hub device and the remote edge device;
- in response to the determination, identify, based on lineage metadata stored on the hub device, a storage location of input data to re-execute the analytical process, wherein the lineage metadata comprises data associated with input data provided to the analytical process, data associated with output data generated by the analytical process, and data identifying the analytical process used to process the input data to generate the output data;
- acquire, on the hub device, the input data from the storage location;
- and
- re-execute, on the hub device, the analytical process based on the input data;
- wherein determine that the analytical process is to be re-executed comprises determine a number of times the analytical process failed to be executed on the hub device, and a number of times a request for the input data is unfulfilled by the remote edge device, due to unavailability of the input data from the remote edge device.
Dependencies are inferred from the claim text.