airflow-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "jack (JIRA)" <j...@apache.org>
Subject [jira] [Updated] (AIRFLOW-2965) Add CLI command to find the next dag run.
Date Mon, 27 Aug 2018 15:01:00 GMT

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

jack updated AIRFLOW-2965:
--------------------------
    Description: 
I have a dag with the following properties:
{code:java}
dag = DAG(
    dag_id='mydag',
    default_args=args,
    schedule_interval='0 1 * * *',
    max_active_runs=1,
    catchup=False){code}
 

 

This runs great.

Last run is: 2018-08-26 01:00  (start date is 2018-08-27 01:00)

 

Now it's 2018-08-27 17:55 I decided to change my dag to:

 
{code:java}
dag = DAG(
    dag_id='mydag',
    default_args=args,
    schedule_interval='0 23 * * *',
    max_active_runs=1,
    catchup=False){code}
 

Now, I have no idea when will be the next dag run.

Will it be today at 23:00? I can't be sure when the cycle is complete. I'm not even sure that
this change will do what I wish.

I'm sure you guys are expert and you can answer this question but most of us wouldn't know.

 

The scheduler has the knowledge when the dag is available for running. All I'm asking is to
take that knowledge and create a CLI command that I will give the dag_id and it will tell
me the next date/hour which my dag will be runnable.

  was:
I have a dag with the following properties:
{code:java}
dag = DAG(
    dag_id='mydag',
    default_args=args,
    schedule_interval='0 1 * * *',
    max_active_runs=1,
    catchup=False){code}
 

 

This runs great.

Last run is: 2018-08-26 01:00  (start date is 2018-08-27 01:00)

 

Now it's 2018-08-27 17:55 I decided to change my dag to:

 
{code:java}
dag = DAG(
    dag_id='mydag',
    default_args=args,
    schedule_interval='0 23 * * *',
    max_active_runs=1,
    catchup=False){code}
 

Now, I have no idea if the dag when will be the next run.

Will it be today at 23:00? I can't be sure when the cycle is complete.

I'm sure you guys are expert and you can answer this question but most of us wouldn't know.

 

The scheduler has the knowledge when the dag is available for running. All I'm asking is to
take that knowledge and create a CLI command that I will give the dag_id and it will tell
me the next date/hour which my dag will be runnable.


> Add CLI command to find the next dag run.
> -----------------------------------------
>
>                 Key: AIRFLOW-2965
>                 URL: https://issues.apache.org/jira/browse/AIRFLOW-2965
>             Project: Apache Airflow
>          Issue Type: Task
>            Reporter: jack
>            Priority: Minor
>             Fix For: 1.10.1
>
>
> I have a dag with the following properties:
> {code:java}
> dag = DAG(
>     dag_id='mydag',
>     default_args=args,
>     schedule_interval='0 1 * * *',
>     max_active_runs=1,
>     catchup=False){code}
>  
>  
> This runs great.
> Last run is: 2018-08-26 01:00  (start date is 2018-08-27 01:00)
>  
> Now it's 2018-08-27 17:55 I decided to change my dag to:
>  
> {code:java}
> dag = DAG(
>     dag_id='mydag',
>     default_args=args,
>     schedule_interval='0 23 * * *',
>     max_active_runs=1,
>     catchup=False){code}
>  
> Now, I have no idea when will be the next dag run.
> Will it be today at 23:00? I can't be sure when the cycle is complete. I'm not even sure
that this change will do what I wish.
> I'm sure you guys are expert and you can answer this question but most of us wouldn't
know.
>  
> The scheduler has the knowledge when the dag is available for running. All I'm asking
is to take that knowledge and create a CLI command that I will give the dag_id and it will
tell me the next date/hour which my dag will be runnable.



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)

Mime
View raw message