GitHub user waardd created a discussion: task routed to wrong queue at random
We have 3 servers.1 is running complete airflow instance and generic worker.
Then we have 2 other servers running a service-worker called rac and dp
Now it looks like some of the task that should run on generic (which is the
default for all airflow configs) are send to the dp worker but they stay queued.
Even when we set the queue in the default args of the DAG
default_args = {
'owner': "operations",
'queue': "generic"
}
How is this possible and how can we solve this?
GitHub link: https://github.com/apache/airflow/discussions/58425
----
This is an automatically sent email for [email protected].
To unsubscribe, please send an email to: [email protected]
