You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@airflow.apache.org by tu...@apache.org on 2020/08/21 14:46:37 UTC
[airflow] branch master updated: Make system test work with 1.10
(#10444)
This is an automated email from the ASF dual-hosted git repository.
turbaszek pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/airflow.git
The following commit(s) were added to refs/heads/master by this push:
new fdd68ec Make system test work with 1.10 (#10444)
fdd68ec is described below
commit fdd68ec653fb9ec4d4c99fac51a6250dea4d7b2c
Author: Tomek Urbaszek <tu...@gmail.com>
AuthorDate: Fri Aug 21 16:45:37 2020 +0200
Make system test work with 1.10 (#10444)
---
tests/test_utils/system_tests_class.py | 5 ++++-
1 file changed, 4 insertions(+), 1 deletion(-)
diff --git a/tests/test_utils/system_tests_class.py b/tests/test_utils/system_tests_class.py
index 63e7c07..7f836ae 100644
--- a/tests/test_utils/system_tests_class.py
+++ b/tests/test_utils/system_tests_class.py
@@ -150,7 +150,10 @@ class SystemTest(TestCase, LoggingMixin):
)
self.log.info("Attempting to run DAG: %s", dag_id)
- dag.clear(dag_run_state=State.NONE)
+ if os.environ.get("RUN_AIRFLOW_1_10") == "true":
+ dag.clear()
+ else:
+ dag.clear(dag_run_state=State.NONE)
try:
dag.run(ignore_first_depends_on_past=True, verbose=True)
except Exception: