ashb commented on issue #22626:
URL: https://github.com/apache/airflow/issues/22626#issuecomment-1094834071

   This _almost_ passes now. The Tasks run, but right at the end of the `test` 
command we have this failure
   
   ```
   [2022-04-11 10:49:28,894]  2990124 MainProcess 
{{airflow.models.taskinstance.TaskInstance taskinstance.py:1364}} INFO - 
Marking task as SUCCESS. dag_id=sys_site_packages_true, 
task_id=dont_install_packages_already_in_outer_environment, map_index=6, 
execution_date=20200410T020000, start_date=20220411T094856, 
end_date=20220411T094928
   Traceback (most recent call last):
     File "/home/ash/.virtualenvs/airflow/bin/airflow", line 33, in <module>
       sys.exit(load_entry_point('apache-airflow', 'console_scripts', 
'airflow')())
     File "/home/ash/code/airflow/airflow/airflow/__main__.py", line 38, in main
       args.func(args)
     File "/home/ash/code/airflow/airflow/airflow/cli/cli_parser.py", line 51, 
in command
       return func(*args, **kwargs)
     File "/home/ash/code/airflow/airflow/airflow/utils/session.py", line 71, 
in wrapper
       return func(*args, session=session, **kwargs)
     File "/home/ash/code/airflow/airflow/airflow/utils/cli.py", line 99, in 
wrapper
       return f(*args, **kwargs)
     File "/home/ash/code/airflow/airflow/airflow/cli/commands/dag_command.py", 
line 446, in dag_test
       dag.run(
     File "/home/ash/code/airflow/airflow/airflow/models/dag.py", line 2226, in 
run
       job.run()
     File "/home/ash/code/airflow/airflow/airflow/jobs/base_job.py", line 244, 
in run
       self._execute()
     File "/home/ash/code/airflow/airflow/airflow/utils/session.py", line 71, 
in wrapper
       return func(*args, session=session, **kwargs)
     File "/home/ash/code/airflow/airflow/airflow/jobs/backfill_job.py", line 
842, in _execute
       self._execute_dagruns(
     File "/home/ash/code/airflow/airflow/airflow/utils/session.py", line 68, 
in wrapper
       return func(*args, **kwargs)
     File "/home/ash/code/airflow/airflow/airflow/jobs/backfill_job.py", line 
732, in _execute_dagruns
       processed_dag_run_dates = self._process_backfill_task_instances(
     File "/home/ash/code/airflow/airflow/airflow/utils/session.py", line 68, 
in wrapper
       return func(*args, **kwargs)
     File "/home/ash/code/airflow/airflow/airflow/jobs/backfill_job.py", line 
612, in _process_backfill_task_instances
       for node, run_id, mapped_tis in 
self._manage_executor_state(ti_status.running, session):
     File "/home/ash/code/airflow/airflow/airflow/jobs/backfill_job.py", line 
269, in _manage_executor_state
       for node in ti.task.mapped_dependants():
     File "/home/ash/code/airflow/airflow/airflow/models/taskmixin.py", line 
317, in mapped_dependants
       raise RuntimeError("Cannot check for mapped_dependants when not attached 
to a DAG")
   RuntimeError: Cannot check for mapped_dependants when not attached to a DAG
   ```


-- 
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.

To unsubscribe, e-mail: [email protected]

For queries about this service, please contact Infrastructure at:
[email protected]

Reply via email to