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: [email protected] With regards, Apache Git Services
