CPC H04L 67/1095 (2013.01) [G06F 9/44 (2013.01); G06F 9/44505 (2013.01); G06F 9/45533 (2013.01); G06F 9/465 (2013.01); G06F 9/48 (2013.01); G06F 9/4806 (2013.01); G06F 9/4843 (2013.01); G06F 9/4881 (2013.01); G06F 9/50 (2013.01); G06F 9/5005 (2013.01); G06F 11/07 (2013.01); G06F 11/0709 (2013.01); G06F 11/14 (2013.01); G06F 8/71 (2013.01); H04L 41/5054 (2013.01)] | 18 Claims |
1. A computer-implemented method of distributed task orchestration, comprising:
detecting, by a processor of a first host of one or more hosts in a distributed computing environment, a distributed task waiting to be started, from a replicated configuration system,
the distributed task being represented by a pending tasks key in the replicated configuration system;
starting, by the processor, the distributed task by performing an atomic compare and swap operation to add a started key to the replicated configuration system for the distributed task;
writing, after the starting, a specification of the distributed task to the replicated configuration system under a new version of a current tasks key,
the specification indicating one or more steps of the distributed task,
the specification further indicating each step of the one or more steps to be executed by at least one host of the one or more hosts;
removing, following the writing, the pending tasks key from the replicated configuration system.
|