Я смотрю на использование воздушного потока для планирования выполнения тестовых случаев для совместно используемого hw в лаборатории и задаю несколько советов о том, как использовать концепцию пула ресурсов для всего экземпляра DAG, а не только на уровне задач.
Как правило, тестовый пример (выполняемый как экземпляр группы DAG для тестового примера (развертывание / выполнение / сбор / развертывание)) определенных физических ресурсов и, следовательно, должен запрашивать их из различных пулов ресурсов (моделируя физический ресурсы), чтобы не столкнуться с конфликтующим одновременным использованием с другими запущенными экземплярами DAG.
У меня вопрос: возможно ли определить использование ресурсов на уровне экземпляра DAG или это возможно только на уровне задач? Если последнее, то будет ли одна параллельная задача, запрашивающая ресурс во время всего выполнения экземпляра DAG, лучшим способом справиться с тем, чтобы не передавать требование ресурса между всеми задачами в DAG? Другие альтернативы?
Обновление после вопросов от Вираджа и Дламблина:
Бег 1.10.1
Запуск LocalExecutor
Проверено, что я могу запускать параллельные DAGS с параллельными задачами
Ресурсы, для которых я хочу иметь настраиваемые пулы, не являются рабочими ресурсами, а представляют собой различные периферийные устройства hw, такие как реле, маршрутизаторы и т. Д., Для которых задачи, выполняемые параллельно на localexecutor, должны блокироваться, если они заняты (0 пользовательских пулов ресурсов / оставленные экземпляры) / -другими задачами