Как получить дату выполнения DAG воздушного потока с помощью командной строки?

Question

Чтобы получить dag_state, я запускаю следующую команду LCI:

airflow dag_state  example_bash_operator '12-12T16:04:46.960661+00:00'

Проблема в том, что я должен явно передать точную дату-время (то есть, значение_даты выполнения) этой команде.Когда я запускаю airflow list_dags, я получаю только список DAG, но не даты их выполнения.

Есть ли способ получить точное время (i.e. -> '12-12T16:04:46.960661+00:00')

для данного знака, используякомандная строка CLI?

Answer 1

Здесь есть концептуальная проблема.Dag s - это объекты, у которых есть расписания, а не даты выполнения.Когда наступит срок выполнения, для этого Dag будет создано DagRun с соответствующим execution_date.

. Таким образом, вы можете запросить состояние DagRun, используя CLI и предоставив execution_date, потому что даты выполнения (почти уникально) отображаются на конкретную DagRun.Почти уникально, потому что на практике вы можете вызвать два DagRun с одним и тем же execution_date, но это необычный сценарий.

Но если вы попросите execution_date из Dag, что вы действительно хотите знать?execution_date из последних недавно созданных DagRun?Список execution_date s для текущей DagRun s?

Вы можете проверить list_dag_runsdag_id CLI и посмотреть, сможет ли yon отфильтровать ее по вашим потребностям.