daemon.clients.flows module

    Bases: daemon.clients.base.AsyncBaseClient

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

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

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

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

      # noqa: DAR101 # noqa: DAR102

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

    Bases: daemon.clients.mixin.AsyncToSyncMixin,

    Client to create/update/delete Flows on remote JinaD