GitHub user trikker added a comment to the discussion: Is there a function that
allows the celery worker provided by airflow to take DAG from the Rabbitmq
Quorum queue?
Yes, @jojaeng2 you are right, after running this command `rabbitmqctl
set_policy ha-all "^default" '{"ha-mode":"all"}' -p test_vhost` and restarting
the rabbitmq node and restarting my celery workers(they crashed because the
default queue cannot be connected), my problem is solved, thanks!
GitHub link:
https://github.com/apache/airflow/discussions/35649#discussioncomment-11300597
----
This is an automatically sent email for [email protected].
To unsubscribe, please send an email to: [email protected]
