daemon.stores.flows module

class daemon.stores.flows.FlowStore[source]

Bases: daemon.stores.containers.ContainerStore, daemon.stores.mixin.AiohttpMixin

A Store of Flows spawned as Containers by Daemon

  • async add_in_partial(uri, params, envs={}, \*kwargs*)[source]

    Sends POST request to partial-daemon to create a Flow.

    • Parameters

      • uri (str) – uri of partial-daemon

      • params (Dict) – Flow params

      • envs (Optional[Dict]) – environment variables to be passed into partial flow

      • kwargs – keyword args

      Return type

      Dict

      Returns

      response from POST request

  • async delete_in_partial(uri, \*kwargs*)[source]

    Sends a DELETE request to partial-daemon to terminate the Flow and, remove the container.

    • Parameters

      • uri (str) – uri of partial-daemon

      • kwargs – keyword args

      Return type

      Dict

      Returns

      response from DELETE request

  • rolling_update(\args, **kwargs*)

  • scale(\args, **kwargs*)