TaskHubGrpcWorker consumes the sidecar stream on a dedicated StreamReader thread and pushes things to the event loop through a queue. We already have grpc.aio in the SDK, we can consume it asynchronously and remove the thread and the queue.
This should not change the public API.
Acceptance criteria:
TaskHubGrpcWorkerconsumes the sidecar stream on a dedicatedStreamReaderthread and pushes things to the event loop through a queue. We already have grpc.aio in the SDK, we can consume it asynchronously and remove the thread and the queue.This should not change the public API.
Acceptance criteria:
WorkflowRuntime.start()/.shutdown()still works