Привет! А в Airflow есть какой-нибудь подобный механизм?
Есть DAG, который в зависимости от очереди может работать 19-26 часов А запускать его нужно каждые 24 часа То есть иногда они могут пересекаться. А я этого не хочу и готов жертвовать этими часами пересечения Сейчас стоит конфиг что не больше одного дага одновременно (именно одинаковых)
А хочется, что если настало время выполнения следующего, он текущий завершал / безбожно убивал под и запускал новый.
дык мне не следующий скипнуть надо, а текущий тормознуть и следующий запустить) С сенсором идея норм, кажется, отлавливать время, отправлять kubectl delete pod и mark as success, но исследую опции)