Provisioning workflows using subgraph similarity
Techniques described herein relate to a method for deploying workflows. The method may include receiving, at a service controller of a federated controller, a request to deploy a workflow in a device ecosystem; decomposing, by the service controller, the workflow into a plurality of workflow portions; performing, by the service controller, a search in a capabilities and constraints data construct to identify a domain in which to perform a workflow portion of the plurality of workflow portions; providing the workflow portion and workflow constraints to a platform controller in the domain; performing, by the platform controller, a subgraph similarity check to determine that a previously executed workflow portion was successfully executed on a subgraph in the domain; provisioning, by the platform controller, a set of devices in the domain based on the subgraph; and executing the workflow portion in the domain.
1. A method for deploying workflows, the method comprising:
receiving, at a service controller of a federated controller, a request to deploy a workflow in a device ecosystem;
decomposing, by the service controller, the workflow into a plurality of workflow portions;
locating an anchor point within the plurality of workflow portions;
performing, by the service controller and based in part on a location of the anchor point, a search in a capabilities and constraints data construct to identify a domain in which to perform a workflow portion of the plurality of workflow portions;
providing the workflow portion and workflow constraints to a platform controller in the domain;
performing, by the platform controller, a subgraph similarity check to determine that a previously executed workflow portion was successfully executed on a subgraph in the domain;
provisioning, by the platform controller, a set of devices in the domain based on the subgraph; and
executing the workflow portion in the domain.
2. The method of claim 1 , wherein the capabilities and constraints data construct comprises a distributed graph.
3. The method of claim 1 , wherein a portion of the workflow constraints are obtained from a service level agreement (SLA) corresponding to the workflow.
4. The method of claim 1 , wherein the anchor point is one selected from a group consisting of a data set and a required capability for a second workflow portion of the plurality of workflow portions.
5. The method of claim 1 , wherein the capabilities and constraints data construct is a database, and the search is performed using database queries.
6. A non-transitory computer readable medium comprising computer readable program code, which when executed by a computer processor enables the computer processor to perform a method for deploying workflows, the method comprising:
receiving, at a service controller of a federated controller, a request to deploy a workflow in a device ecosystem;
decomposing, by the service controller, the workflow into a plurality of workflow portions;
locating an anchor point within the plurality of workflow portions;
performing, by the service controller and based in part on a location of the anchor point, a search in a capabilities and constraints data construct to identify a domain in which to perform a workflow portion of the plurality of workflow portions;
providing the workflow portion and workflow constraints to a platform controller in the domain;
performing, by the platform controller, a subgraph similarity check to determine that a previously executed workflow portion was successfully executed on a subgraph in the domain;
provisioning, by the platform controller, a set of devices in the domain based on the subgraph; and
executing the workflow portion in the domain.
7. The non-transitory computer readable medium of claim 6 , wherein the capabilities and constraints data construct comprises a distributed graph.
8. The non-transitory computer readable medium of claim 6 , wherein a portion of the workflow constraints are obtained from a service level agreement (SLA) corresponding to the workflow.
9. The non-transitory computer readable medium of claim 6 , wherein the anchor point is one selected from a group consisting of a data set and a required capability for a second workflow portion of the plurality of workflow portions.
10. The non-transitory computer readable medium of claim 6 , wherein the capabilities and constraints data construct is a database, and the search is performed using database queries.
11. A system for deploying workflows, the system comprising:
a federated controller for a device ecosystem, the federated controller comprising a plurality of service controllers;
a service controller of the federated controller, comprising a processor and memory, and configured to:
receive a request to deploy a workflow in a device ecosystem;
decompose the workflow into a plurality of workflow portions;
locate an anchor point within the plurality of workflow portions;
perform, based in part on a location of the anchor point, a search in a capabilities and constraints data construct to identify a domain in which to perform a workflow portion of the plurality of workflow portions; and
provide the workflow portion and workflow constraints to a platform controller in the domain; and
the platform controller, comprising circuitry, and configured to:
perform a subgraph similarity check to determine that a previously executed workflow portion was successfully executed on a subgraph in the domain;
provision a set of devices in the domain based on the subgraph; and
initiate execution of the workflow portion in the domain.
12. The system of claim 11 , wherein the capabilities and constraints data construct comprises a distributed graph.
13. The system of claim 11 , wherein a portion of the workflow constraints are obtained from a service level agreement (SLA) corresponding to the workflow.
14. The system of claim 11 , wherein the anchor point is one selected from a group consisting of a data set and a required capability for a second workflow portion of the plurality of workflow portions.
15. The system of claim 11 , wherein the capabilities and constraints data construct is a database, and the search is performed using database queries.