Как я могу гарантировать, что в Airflow в любой момент времени работает только 1 экземпляр оператора (используется в нескольких пакетах)?

Question

Я использую оператор (оператор subdag, с taskid "XYZ") в DAG A, и у меня также есть другой оператор subdag с таким же taskid (то есть "XYZ") в DAG B.Учитывая этот сценарий, как я могу гарантировать, что не более 1 экземпляра "XYZ" работает в любой момент времени.DAG A и DAG B могут работать параллельно.

Answer 1

Задача состояла в том, чтобы создать пул с 1 рабочим слотом и назначить этот пул идентификаторам задач, которые не могут быть запущены одновременно.В этом случае у меня был только один идентификатор задачи (оператор) XYZ, где я должен был убедиться, что его экземпляры не запускаются одновременно.

Не уверен, что это идиоматический способ, но у меня сработало!