Deploy Worker for Camunda Cloud in Python

Hi all,

I am struggling to get a running instance of a worker connected to a Camunda Cloud instance. I tried to replicate the code in Python here: camunda-8-code-studio/PythonCloudWorker.py at main · camunda-community-hub/camunda-8-code-studio · GitHub

Unfortunately, I get an error in the loop.run_until_complete(worker.work()) line with the following message:

grpc.aio._call.AioRpcError: <AioRpcError of RPC that terminated with:
status = StatusCode.UNKNOWN
details = “Stream removed”
debug_error_string = “UNKNOWN:Error received from peer ipv4:xxxx {grpc_message:“Stream removed”, grpc_status:2, created_time:“2022-09-07T07:54:54.2813531+00:00”}”

Does anyone know how to fix this?

I was able to fix it now using task routers and by realizing that when using create_camunda_cloud_channel the region setting might be relevant (default is ‘bru-2’).

2 Likes