daemon.clients.flows module

class daemon.clients.flows.AsyncFlowClient(uri, logger, timeout=None)[source]

Bases: daemon.clients.base.AsyncBaseClient

Async Client to create/update/delete Flows on remote JinaD

  • async arguments(\args, **kwargs*)

  • async create(\args, **kwargs*)

    Create a Workspace/Flow/Pod/Deployment on remote. Must be implemented by the inherited class.

    # noqa: DAR101 # noqa: DAR102

  • async rolling_update(\args, **kwargs*)

  • async scale(\args, **kwargs*)

  • async delete(\args, **kwargs*)

    Delete a Workspace/Flow/Pod/Deployment on remote. Must be implemented by the inherited class.

    # noqa: DAR101 # noqa: DAR102

class daemon.clients.flows.FlowClient(uri, logger, timeout=None)[source]

Bases: daemon.clients.mixin.AsyncToSyncMixin, daemon.clients.flows.AsyncFlowClient

Client to create/update/delete Flows on remote JinaD