George Leslie-Waksman created AIRFLOW-2787:
----------------------------------------------
Summary: Airflow scheduler dies on DAGs with NULL DagRun run_id
Key: AIRFLOW-2787
URL: https://issues.apache.org/jira/browse/AIRFLOW-2787
Project: Apache Airflow
Issue Type: Bug
Reporter: George Leslie-Waksman
When a DagRun is created with NULL run_id, the scheduler subprocess will crash
when checking `is_backfill`:
{noformat}
Got an exception! Propagating...
Traceback (most recent call last):
File "/usr/local/lib/python3.6/site-packages/airflow/jobs.py", line 347, in
helper
pickle_dags)
File "/usr/local/lib/python3.6/site-packages/airflow/utils/db.py", line 53,
in wrapper
result = func(*args, **kwargs)
File "/usr/local/lib/python3.6/site-packages/airflow/jobs.py", line 1583, in
process_file
self._process_dags(dagbag, dags, ti_keys_to_schedule)
File "/usr/local/lib/python3.6/site-packages/airflow/jobs.py", line 1175, in
_process_dags
self._process_task_instances(dag, tis_out)
File "/usr/local/lib/python3.6/site-packages/airflow/jobs.py", line 873, in
_process_task_instances
if run.is_backfill:
File "/usr/local/lib/python3.6/site-packages/airflow/models.py", line 4257,
in is_backfill
if "backfill" in self.run_id:
TypeError: argument of type 'NoneType' is not iterable
{noformat}
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
