I’m using this code to get available workers for a give queue (in this case all possible queues)
for queue in all_queues:
request = DescribeTaskQueueRequest(
namespace=TEMPORAL_NAMESPACE,
task_queue={"name": queue},
)
task_queue_info = await client.workflow_service.describe_task_queue(request)
worker_count = task_queue_info.pollers
...
time.sleep(0.075)
The problem is that without the sleep I am getting rate limit, but I still not identified which limit it is and how can I increase this limit or perhaps if there is a better way to achieve this.
Thanks!