You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@airflow.apache.org by "Pierre-Antoine Tible (JIRA)" <ji...@apache.org> on 2017/06/20 16:11:00 UTC
[jira] [Created] (AIRFLOW-1328) Daily DAG execute the past day
Pierre-Antoine Tible created AIRFLOW-1328:
---------------------------------------------
Summary: Daily DAG execute the past day
Key: AIRFLOW-1328
URL: https://issues.apache.org/jira/browse/AIRFLOW-1328
Project: Apache Airflow
Issue Type: Bug
Components: DagRun
Affects Versions: Airflow 1.8
Environment: debian jessie
Reporter: Pierre-Antoine Tible
Hello,
I'm running Airflow 1.8 under debian jessie. I installed it via pip.
I am using the LocalScheduler with a Mysql.
I made a simple DAG with a BashOperator for a daily task (two times) :
+_default_args = {
'owner': 'airflow',
'depends_on_past': False,
'start_date': datetime.now() - timedelta(days=1, seconds=6),
'email': ['XXX'],
'email_on_failure': True,
'email_on_retry': False,
'retries': 1,
'retry_delay': timedelta(minutes=5),
'execution_timeout': None,
#'catchup': False,
#'backfill': False,
# 'queue': 'bash_queue',
# 'pool': 'backfill',
# 'priority_weight': 10,
# 'end_date': datetime(2016, 1, 1),
}
dag = DAG('campaign-reminder', default_args=default_args, schedule_interval="0,0 7,15 * * *", concurrency=1, max_active_runs=1)
dag.catchup = False
t1 = BashOperator(
task_id='campaign-reminder',
bash_command='XXXX ',
dag=dag)_+
I did it today, it works, but the execution date was "06-19T15:00:00", we are the 20th, so it's one day behind the schedule.
My first though was a mistake with the start_date, so I put a datetime() and it did the same ...
I don't understand why.
--
This message was sent by Atlassian JIRA
(v6.4.14#64029)