airflow-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Shashi Kant Sharms (JIRA)" <j...@apache.org>
Subject [jira] [Updated] (AIRFLOW-905) Support querying dag_run state by run_id
Date Sat, 25 Feb 2017 06:41:44 GMT

     [ https://issues.apache.org/jira/browse/AIRFLOW-905?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]

Shashi Kant Sharms updated AIRFLOW-905:
---------------------------------------
    Description: 
Support querying dag_run and task_instances by run_id. Currently run id is supported in trigger
dag command but it is no used in any of querying command.

Existing Commands :
# airflow dag_state [-h] [-sd SUBDIR] dag_id execution_date

# airflow task_state [-h] [-sd SUBDIR] dag_id task_id execution_date

New Commands :
# airflow dag_state [-h] [-sd SUBDIR] dag_id execution_date|run_id

# airflow task_state [-h] [-sd SUBDIR] dag_id task_id execution_date|run_id

For dag state change we can pass run id from CLI and pass the same in find function for Dags.
for task_state we need to modify the Task Instance model to include run id and then we can
find based upon run id as well. As part of this we will make execution date as optional attribute
for task instance find function. 

As part of this change I'll also include run id in "airflow run"  and "airflow render"  commands.
Details will follow around this. 

  was:
Initial analysis:
There are two commands dag_state and task_state
for dag state change we can pass run id from CLI and pass the same in find function for Dags.
for task_state we need to modify the Task Instance model to include run id and then we can
find based upon run id as well. As part of this we will make execution date as optional attribute
for task instance find function. 

Also including run id in "airflow run"  and "airflow render"  


> Support querying dag_run state by run_id
> ----------------------------------------
>
>                 Key: AIRFLOW-905
>                 URL: https://issues.apache.org/jira/browse/AIRFLOW-905
>             Project: Apache Airflow
>          Issue Type: New Feature
>          Components: cli
>            Reporter: Shashi Kant Sharms
>            Assignee: Shashi Kant Sharms
>            Priority: Minor
>
> Support querying dag_run and task_instances by run_id. Currently run id is supported
in trigger dag command but it is no used in any of querying command.
> Existing Commands :
> # airflow dag_state [-h] [-sd SUBDIR] dag_id execution_date
> # airflow task_state [-h] [-sd SUBDIR] dag_id task_id execution_date
> New Commands :
> # airflow dag_state [-h] [-sd SUBDIR] dag_id execution_date|run_id
> # airflow task_state [-h] [-sd SUBDIR] dag_id task_id execution_date|run_id
> For dag state change we can pass run id from CLI and pass the same in find function for
Dags.
> for task_state we need to modify the Task Instance model to include run id and then we
can find based upon run id as well. As part of this we will make execution date as optional
attribute for task instance find function. 
> As part of this change I'll also include run id in "airflow run"  and "airflow render"
 commands. Details will follow around this. 



--
This message was sent by Atlassian JIRA
(v6.3.15#6346)

Mime
View raw message