[AIRFLOW-XXX] Raise ValueError rather than assert in skip logic (apac…

…he#5875)
george79diakos · Aug 21, 2019 · aa8a300 · aa8a300
1 parent b7cdedc
commit aa8a300
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/airflow/models/skipmixin.py b/airflow/models/skipmixin.py
@@ -54,7 +54,8 @@ def skip(self, dag_run, execution_date, tasks, session=None):
                      synchronize_session=False)
             session.commit()
         else:
-            assert execution_date is not None, "Execution date is None and no dag run"
+            if execution_date is None:
+                raise ValueError("Execution date is None and no dag run")
 
             self.log.warning("No DAG RUN present this should not happen")
             # this is defensive against dag runs that are not complete