soulfire.task_connect.BotTaskServiceClientSync

class soulfire.task_connect.BotTaskServiceClientSync(address: str, *, codec: connectrpc.codec.Codec | None = _PROTO_BINARY_CODEC, protocol: connectrpc.protocol.ProtocolType = ProtocolType.CONNECT, accept_compression: collections.abc.Iterable[connectrpc.compression.Compression] | None = None, send_compression: connectrpc.compression.Compression | None = _GZIP_COMPRESSION, timeout_ms: int | None = None, read_max_bytes: int | None = None, interceptors: collections.abc.Iterable[connectrpc.interceptor.InterceptorSync] = (), http_client: pyqwest.SyncClient | None = None)

Bases: connectrpc.client.ConnectClientSync

A synchronous client for the Connect protocol.

start_bot_task(request: soulfire.task_pb2.StartBotTaskRequest, *, headers: connectrpc.request.Headers | collections.abc.Mapping[str, str] | None = None, timeout_ms: int | None = None) → soulfire.task_pb2.BotTask

run_bot_task(request: soulfire.task_pb2.StartBotTaskRequest, *, headers: connectrpc.request.Headers | collections.abc.Mapping[str, str] | None = None, timeout_ms: int | None = None) → collections.abc.Iterator[soulfire.task_pb2.BotTaskEvent]

get_bot_task(request: soulfire.task_pb2.GetBotTaskRequest, *, headers: connectrpc.request.Headers | collections.abc.Mapping[str, str] | None = None, timeout_ms: int | None = None) → soulfire.task_pb2.BotTask

list_bot_tasks(request: soulfire.task_pb2.ListBotTasksRequest, *, headers: connectrpc.request.Headers | collections.abc.Mapping[str, str] | None = None, timeout_ms: int | None = None) → soulfire.task_pb2.ListBotTasksResponse

watch_bot_task(request: soulfire.task_pb2.WatchBotTaskRequest, *, headers: connectrpc.request.Headers | collections.abc.Mapping[str, str] | None = None, timeout_ms: int | None = None) → collections.abc.Iterator[soulfire.task_pb2.BotTaskEvent]

watch_bot_tasks(request: soulfire.task_pb2.WatchBotTasksRequest, *, headers: connectrpc.request.Headers | collections.abc.Mapping[str, str] | None = None, timeout_ms: int | None = None) → collections.abc.Iterator[soulfire.task_pb2.BotTaskEvent]

cancel_bot_task(request: soulfire.task_pb2.CancelBotTaskRequest, *, headers: connectrpc.request.Headers | collections.abc.Mapping[str, str] | None = None, timeout_ms: int | None = None) → soulfire.task_pb2.BotTask