Перейти к содержимому

Управление очередями запуска

Pools — это механизм ограничения параллельного выполнения задач, позволяющий контролировать, сколько задач (из одного или нескольких DAG’ов) могут выполняться одновременно.

image_1

Рекомендации

Если программные роботы взаимодействуют с десктопными приложениями или браузером в видимом (GUI) режиме, рекомендуется запускать их через выделенную очередь с ограничением на количество одновременно выполняемых задач. Это предотвращает конфликты и перегрузку графической сессии.

Создание очереди

Для создания новой очереди требуется:

  1. Открыть раздел пользовательского интерфейса оркестратора Airflow;
  2. Перейти в раздел Pools: image_2
  3. Кликнуть на кнопку Add a new record: image_3
  4. Указать:
    • Pool - название очереди;

      Тип данных: str (Строка)

      Пример: default_pool

    • Slots - количество одновременно запускаемых задач;

      Тип данных: int (Целое число)

      Пример: 1

    • Description - описание очереди;

      Тип данных: str (Строка)

      Пример: Очередь для запуска роботов

    image_4
  5. Кликнуть на кнопку Save для сохранения созданной записи.

Использование очереди

Чтобы использовать созданную очередь, укажите её название в соответствующем поле блока Создать процесс (Dag).

image_5