Kaxil Naik created AIRFLOW-3006:
-----------------------------------
Summary: 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.10.0, 1.9.0, 1.8.2
Reporter: Kaxil Naik
Assignee: Kaxil Naik
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)
