daemon.clients.flows module#
- class daemon.clients.flows.AsyncFlowClient(uri, logger, timeout=None)[source]#
Bases:
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:
AsyncToSyncMixin
,AsyncFlowClient
Client to create/update/delete Flows on remote JinaD