Worker Affinity

Worker Affinity with Task Queues allows ensuring that multiple Activities within a workflow execute on the same Worker. This is achieved by using a combination of shared and unique task queues. The workflow first discovers an available worker via a shared queue and then routes all subsequent activities to that worker's unique queue, maintaining data locality for scenarios like file processing, ML model caching, and database connection pooling. This post details how to route specialized workloads.