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)