[jira] [Closed] (AIRFLOW-3006) Error when schedule_interval="None"

["Siddharth Anand (JIRA)" <ji...@apache.org>]

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

Siddharth Anand closed AIRFLOW-3006.
------------------------------------
    Resolution: Fixed

> Error when schedule_interval="None"
> -----------------------------------
>
>                 Key: AIRFLOW-3006
>                 URL: https://issues.apache.org/jira/browse/AIRFLOW-3006
>             Project: Apache Airflow
>          Issue Type: Improvement
>          Components: core, scheduler
>    Affects Versions: 1.8.2, 1.9.0, 1.10.0
>            Reporter: Kaxil Naik
>            Assignee: Kaxil Naik
>            Priority: Major
>             Fix For: 1.10.1
>
>
> When `schedule_interval` is set to `"None"`, it gives the following error:
> {code:python}
> dag = DAG('params-temp3',
>           default_args=default_args, schedule_interval='None')
> {code}
> {code:python}
> [2018-09-04 23:26:21,515] {dag_processing.py:582} INFO - Started a process (PID: 65903) to generate tasks for /Users/kaxil/airflow/dags/params-temp1.py
> Process DagFileProcessor386-Process:
> Traceback (most recent call last):
>   File "/Users/kaxil/anaconda2/lib/python2.7/multiprocessing/process.py", line 267, in _bootstrap
>     self.run()
>   File "/Users/kaxil/anaconda2/lib/python2.7/multiprocessing/process.py", line 114, in run
>     self._target(*self._args, **self._kwargs)
>   File "/Users/kaxil/.virtualenvs/tst-pip-airflow/lib/python2.7/site-packages/airflow/jobs.py", line 388, in helper
>     pickle_dags)
>   File "/Users/kaxil/.virtualenvs/tst-pip-airflow/lib/python2.7/site-packages/airflow/utils/db.py", line 74, in wrapper
>     return func(*args, **kwargs)
>   File "/Users/kaxil/.virtualenvs/tst-pip-airflow/lib/python2.7/site-packages/airflow/jobs.py", line 1832, in process_file
>     self._process_dags(dagbag, dags, ti_keys_to_schedule)
>   File "/Users/kaxil/.virtualenvs/tst-pip-airflow/lib/python2.7/site-packages/airflow/jobs.py", line 1422, in _process_dags
>     dag_run = self.create_dag_run(dag)
>   File "/Users/kaxil/.virtualenvs/tst-pip-airflow/lib/python2.7/site-packages/airflow/utils/db.py", line 74, in wrapper
>     return func(*args, **kwargs)
>   File "/Users/kaxil/.virtualenvs/tst-pip-airflow/lib/python2.7/site-packages/airflow/jobs.py", line 856, in create_dag_run
>     next_run_date = dag.normalize_schedule(min(task_start_dates))
>   File "/Users/kaxil/.virtualenvs/tst-pip-airflow/lib/python2.7/site-packages/airflow/models.py", line 3410, in normalize_schedule
>     following = self.following_schedule(dttm)
>   File "/Users/kaxil/.virtualenvs/tst-pip-airflow/lib/python2.7/site-packages/airflow/models.py", line 3353, in following_schedule
>     cron = croniter(self._schedule_interval, dttm)
>   File "/Users/kaxil/.virtualenvs/tst-pip-airflow/lib/python2.7/site-packages/croniter/croniter.py", line 92, in __init__
>     self.expanded, self.nth_weekday_of_month = self.expand(expr_format)
>   File "/Users/kaxil/.virtualenvs/tst-pip-airflow/lib/python2.7/site-packages/croniter/croniter.py", line 467, in expand
>     raise CroniterBadCronError(cls.bad_length)
> CroniterBadCronError: Exactly 5 or 6 columns has to be specified for iteratorexpression.
> [2018-09-04 23:26:22,657] {dag_processing.py:495} INFO - Processor for /Users/kaxil/airflow/dags/params-temp1.py finished
> {code}



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