Synchronising datasets updates
An apparatus, computer-implemented method and computer program are disclosed for synchronising dataset updates. For example, the method may comprise providing a first code branch associated with a plurality of code sets which, when executed, produce respective time-series datasets for provision to a downstream process linked to the first code branch. The method may also comprise generating a second code branch, based on the first code branch, the second code branch executing the plurality of code sets as part of an updating process and, if successful, storing respective time-series datasets to respective memory locations associated with the second code branch. Another part of the method may comprise determining if all code sets executed by the second code branch have successfully committed. Responsive to a positive determination, one or more pointers, e.g. all pointers, associated with the first code branch may be updated to point to the respective memory locations associated with the second code branch in order that the respective successfully-committed time-series datasets are provided to the downstream process.
1 . A computer-implemented method, wherein the method is performed using one or more processors, the method comprising:
providing a first code branch associated with a plurality of code sets which, when executed, produce respective first time-series datasets, stored in a first memory location, for provision to a downstream process linked to the first code branch;
providing an update to a downstream process that the first time-series datasets are stored in the first memory location via a first pointer to the first memory location;
generating a second code branch, based on the first code branch, the second code branch executing the plurality of code sets and, if successfully committed, storing respective second time-series datasets, stored in a second memory location;
determining if all code sets executed by the second code branch have successfully committed;
responsive to a negative determination, regenerating the second code branch based on a different version of the second code branch in a recursive process until the second code branch is successfully generated; and
responsive to a positive determination, providing an update to the downstream process.
2 . The computer-implemented method of claim 1 , wherein the method further comprises:
responsive to a negative determination, deleting the second code branch.
3 . The computer-implemented method of claim 1 , wherein the method further comprises:
detecting an updating event associated with the first code branch; and
generating the second code branch and executing the plurality of code sets responsive to detection of the updating event.
4 . The computer-implemented method of claim 1 , wherein the update to the downstream process indicates that the second time-series datasets are stored in the second memory location via a second pointer to the second memory location.
5 . The computer-implemented method of claim 1 , wherein generating the second code branch comprises replicating the plurality of code sets associated with the first code branch and executing the replicated plurality of code sets as part of the updating process independently of the plurality of code sets associated with the first code branch.
6 . The computer-implemented method of claim 1 , wherein the first code branch is associated with respective memory locations which, by means of the updated one or more pointers, point to the respective memory locations associated with the second code branch.
7 . The computer-implemented method of claim 1 , wherein the plurality of code sets comprise code which, when executed, receives or causes receipt of, in one time-series dataset, data representing component failure reports and, in another time-series dataset, data representing at least a set of entities and constituent components of the entities, the downstream process being configured to identify entities having constituent components that require updating or servicing based on the component failure reports.
8 . A computing system comprising:
one or more processors; and
memory storing instructions that, when executed by the one or more processors, cause the computing system to perform:
providing a first code branch associated with a plurality of code sets which, when executed, produce respective first time-series datasets, stored in a first memory location, for provision to a downstream process linked to the first code branch;
providing an update to a downstream process that the first time-series datasets are stored in the first memory location via a first pointer to the first memory location;
generating a second code branch, based on the first code branch, the second code branch executing the plurality of code sets and, if successfully committed, storing respective second time-series datasets, stored in a second memory location;
determining if all code sets executed by the second code branch have successfully committed;
responsive to a negative determination, regenerating the second code branch based on a different version of the second code branch in a recursive process until the second code branch is successfully generated; and
responsive to a positive determination, providing an update to the downstream process.
9 . The computing system of claim 8 , wherein the instructions further cause the computing system to perform:
responsive to a negative determination, deleting the second code branch.
10 . The computing system of claim 8 , wherein the instructions further cause the computing system to perform:
detecting an updating event associated with the first code branch; and
generating the second code branch and executing the plurality of code sets responsive to detection of the updating event.
11 . The computing system of claim 8 , wherein the update to the downstream process indicates that the second time-series datasets are stored in the second memory location via a second pointer to the second memory location.
12 . The computing system of claim 8 , wherein the generating of the second code branch comprises replicating the plurality of code sets associated with the first code branch and executing the replicated plurality of code sets as part of the updating process independently of the plurality of code sets associated with the first code branch.
13 . The computing system of claim 8 , wherein the first code branch is associated with respective memory locations which, by means of the updated one or more pointers, point to the respective memory locations associated with the second code branch.
14 . The computing system of claim 8 , wherein the plurality of code sets comprise code which, when executed, receives or causes receipt of, in one time-series dataset, data representing component failure reports and, in another time-series dataset, data representing at least a set of entities and constituent components of the entities, the downstream process being configured to identify entities having constituent components that require updating or servicing based on the component failure reports.
15 . A computer program product comprising a non-transitory computer-readable medium readable by a processing circuit, the non-transitory computer-readable medium storing instructions executable by the processing circuit to cause a method to be performed, the method comprising:
providing a first code branch associated with a plurality of code sets which, when executed, produce respective first time-series datasets, stored in a first memory location, for provision to a downstream process linked to the first code branch;
providing an update to a downstream process that the first time-series datasets are stored in the first memory location via a first pointer to the first memory location;
generating a second code branch, based on the first code branch, the second code branch executing the plurality of code sets and, if successfully committed, storing respective second time-series datasets, stored in a second memory location;
determining if all code sets executed by the second code branch have successfully committed;
responsive to a negative determination, regenerating the second code branch based on a different version of the second code branch in a recursive process until the second code branch is successfully generated; and
responsive to a positive determination, providing an update to the downstream process.
16 . The computer program product of claim 15 , wherein the method comprises:
responsive to a negative determination, deleting the second code branch.
17 . The computer program product of claim 15 , wherein the method further comprises:
detecting an updating event associated with the first code branch; and
generating the second code branch and executing the plurality of code sets responsive to detection of the updating event.
18 . The computer program product of claim 15 , wherein the update to the downstream process indicates that the second time-series datasets are stored in the second memory location via a second pointer to the second memory location.
19 . The computer program product of claim 15 , wherein generating the second code branch comprises replicating the plurality of code sets associated with the first code branch and executing the replicated plurality of code sets as part of the updating process independently of the plurality of code sets associated with the first code branch.
20 . The computer program product of claim 15 , wherein the first code branch is associated with respective memory locations which, by means of the updated one or more pointers, point to the respective memory locations associated with the second code branch.