Изменение рабочей очереди в реальном времени в Apache Airflow

В Apache Airflow я могу указать рабочую очередь при запуске рабочего.

У меня есть вариант использования, когда я хотел бы изменить очередь, которую рабочий использует в прямом эфире, чтобы существующий рабочий вытягивал новые задания из этой очереди.

Это возможно?


person ignorance    schedule 22.05.2019    source источник


Ответы (1)


Насколько я могу судить, нет. Вы можете запустить рабочего с помощью airflow worker -q <queue>, но, похоже, нет способа убить этого рабочего или вообще взаимодействовать с ним после его появления.

person roflcopter1101    schedule 27.11.2019