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:18 UTC

[airflow] branch random-check-on-test-to-be-deleted created (now 74544f4)

This is an automated email from the ASF dual-hosted git repository.

xddeng pushed a change to branch random-check-on-test-to-be-deleted
in repository https://gitbox.apache.org/repos/asf/airflow.git.


      at 74544f4  Random check on test. This branch will be deleted

This branch includes the following new commits:

     new 74544f4  Random check on test. This branch will be deleted

The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails.  The revisions
listed as "add" were already present in the repository and have only
been added to this reference.



[airflow] 01/01: Random check on test. This branch will be deleted

Posted by xd...@apache.org.
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),
         ]