airflow-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From GitBox <...@apache.org>
Subject [GitHub] [airflow] OmerJog commented on issue #4751: [AIRFLOW-3607] collected trigger rule dep check per dag run
Date Tue, 26 Nov 2019 13:15:56 GMT
OmerJog commented on issue #4751: [AIRFLOW-3607] collected trigger rule dep check per dag run
URL: https://github.com/apache/airflow/pull/4751#issuecomment-558623032
 
 
   @amichai07 still there are errors:
   
   ```
   43) ERROR: test_backfill_examples_0_example_branch_operator (tests.jobs.test_backfill_job.TestBackfillJob)
   ----------------------------------------------------------------------
      Traceback (most recent call last):
       /usr/local/lib/python3.6/site-packages/parameterized/parameterized.py line 518 in standalone_func
         return func(*(a + p.args), **p.kwargs)
       tests/jobs/test_backfill_job.py line 274 in test_backfill_examples
         job.run()
       airflow/jobs/base_job.py line 217 in run
         self._execute()
       airflow/utils/db.py line 68 in wrapper
         return func(*args, **kwargs)
       airflow/jobs/backfill_job.py line 766 in _execute
         session=session)
       airflow/utils/db.py line 64 in wrapper
         return func(*args, **kwargs)
       airflow/jobs/backfill_job.py line 696 in _execute_for_run_dates
         session=session)
       airflow/utils/db.py line 64 in wrapper
         return func(*args, **kwargs)
       airflow/jobs/backfill_job.py line 582 in _process_backfill_task_instances
         _per_task_process(task, key, ti)
       airflow/utils/db.py line 68 in wrapper
         return func(*args, **kwargs)
       airflow/jobs/backfill_job.py line 475 in _per_task_process
         verbose=self.verbose):
       airflow/utils/db.py line 64 in wrapper
         return func(*args, **kwargs)
       airflow/models/taskinstance.py line 603 in are_dependencies_met
         session=session):
       airflow/models/taskinstance.py line 627 in get_failed_dep_statuses
         dep_context):
       airflow/ti_deps/deps/base_ti_dep.py line 106 in get_dep_statuses
         yield from self._get_dep_statuses(ti, session, dep_context)
       airflow/ti_deps/deps/trigger_rule_dep.py line 68 in _get_dep_statuses
         state=State.finished() + [State.UPSTREAM_FAILED], session=session)\
      AttributeError: 'list' object has no attribute 'options'
      -------------------- >> begin captured logging << --------------------
      tests.jobs.test_backfill_job: INFO: *** Running example DAG: example_branch_operator
      tests.executors.test_executor.TestExecutor: INFO: Adding to queue: ['airflow', 'tasks',
'run', 'example_branch_operator', 'run_this_first', '2016-01-01T00:00:00+00:00', '--pickle',
'4', '-I', '--local', '--pool', 'default_pool']
      --------------------- >> end captured logging << ---------------------
   ```
   
   
   
   ```
   ======================================================================
   48) FAIL: test_backfill_max_limit_check (tests.jobs.test_backfill_job.TestBackfillJob)
   ----------------------------------------------------------------------
      Traceback (most recent call last):
       tests/jobs/test_backfill_job.py line 972 in test_backfill_max_limit_check
         self.assertEqual(3, len(dagruns))  # 2 from backfill + 1 existing
      AssertionError: 3 != 2
      -------------------- >> begin captured logging << --------------------
      tests.executors.test_executor.TestExecutor: INFO: Adding to queue: ['airflow', 'tasks',
'run', 'test_backfill_max_limit_check', 'leave1', '2015-12-31T23:00:00+00:00', '--local',
'--pool', 'default_pool']
      --------------------- >> end captured logging << ---------------------
   ```

----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
 
For queries about this service, please contact Infrastructure at:
users@infra.apache.org


With regards,
Apache Git Services

Mime
View raw message