You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@airflow.apache.org by xd...@apache.org on 2020/11/27 20:11:19 UTC
[airflow] 01/01: Random check on test. This branch will be deleted
This is an automated email from the ASF dual-hosted git repository.
xddeng pushed a commit to branch random-check-on-test-to-be-deleted
in repository https://gitbox.apache.org/repos/asf/airflow.git
commit 74544f4bdbd036f80a231efe6551796869f23004
Author: Xiaodong DENG <xd...@gmail.com>
AuthorDate: Fri Nov 27 21:10:19 2020 +0100
Random check on test. This branch will be deleted
---
tests/jobs/test_scheduler_job.py | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
diff --git a/tests/jobs/test_scheduler_job.py b/tests/jobs/test_scheduler_job.py
index ab406be..063a391 100644
--- a/tests/jobs/test_scheduler_job.py
+++ b/tests/jobs/test_scheduler_job.py
@@ -520,7 +520,7 @@ class SchedulerJobTest(unittest.TestCase):
scheduler_job._process_task_instances(dag, task_instances_list=ti_to_schedule)
assert ti_to_schedule == [
- (dag.dag_id, dag_task1.task_id, DEFAULT_DATE, TRY_NUMBER),
+ (dag.dag_id, "abc", DEFAULT_DATE, TRY_NUMBER),
]
@parameterized.expand([
@@ -571,7 +571,7 @@ class SchedulerJobTest(unittest.TestCase):
scheduler_job._process_task_instances(dag, task_instances_list=ti_to_schedule)
assert ti_to_schedule == [
- (dag.dag_id, dag_task1.task_id, DEFAULT_DATE, TRY_NUMBER),
+ (dag.dag_id, dag_task1.task_id, DEFAULT_DATE, TRY_NUMBER + 1),
(dag.dag_id, dag_task2.task_id, DEFAULT_DATE, TRY_NUMBER),
]