может, и можно. я не настоящий сварщик, с airflow работал буквально ничего
аналогично=) я сам присматриваюсь к их доке и апи, вроде как сенсор для таких кейсов и задумывался вот интересно какие есть подходы к подобному
как бы там ни было в итоге, нужно для такой reactive execution предусмотреть вещи вроде: - сообщение пришло дважды - сообщение пришло, даг запустился, но упал - пришло 30 сообщений, даг мертв. будем процессить все 30 или наш даг умеет, посмотрев в последнее, забить на предыдущие 29 и не тратить зря ресурсы на их обраьотку?
Обсуждают сегодня