Version: 0.26.0

Task Queues

When a workflow invokes an activity, it sends the ScheduleActivityTask decision to the Temporal service. As a result, the service updates the workflow state and dispatches an activity task to a worker that implements the activity. Instead of calling the worker directly, an intermediate queue is used. So the service adds an activity task to this queue and a worker receives the task using a long poll request. Temporal calls this queue used to dispatch activity tasks an activity task queue.

Similarly, when a workflow needs to handle an external event, a decision task is created. A Decision task queue is used to deliver it to the workflow worker (also called decider).

While Temporal task queues are queues, they have some differences from commonly used queuing technologies. The main one is that they do not require explicit registration and are created on demand. The number of task queues is not limited. A common use case is to have a task queue per worker process and use it to deliver activity tasks to the process. Another use case is to have a task queue per pool of workers.

There are multiple advantages of using a task queue to deliver tasks instead of invoking an activity worker through a synchronous RPC:

  • Worker doesn't need to have any open ports, which is more secure.
  • Worker doesn't need to advertise itself through DNS or any other network discovery mechanism.
  • When all workers are down, messages are persisted in a task queue waiting for the workers to recover.
  • A worker polls for a message only when it has spare capacity, so it never gets overloaded.
  • Automatic load balancing across a large number of workers.
  • Task queues support server side throttling. This allows you to limit the task dispatch rate to the pool of workers and still supports adding a task with a higher rate when spikes happen.
  • Task queues can be used to route a request to specific pools of workers or even a specific process.