aritra24 commented on PR #41067:
URL: https://github.com/apache/airflow/pull/41067#issuecomment-2258130910
I was trying to figure out test_python. It looks like the dags are not
getting committed?
```
[2024-07-30T09:53:52.608+0000] {taskinstance.py:2735} INFO - Id is
dag_testpythonoperator and in dagbag is []
[2024-07-30T09:53:52.611+0000] {rpc_api_endpoint.py:160} ERROR - Error
executing method
'airflow.models.taskinstance.TaskInstance._check_and_change_state_before_execution'.
error_id=bfb26504-0e80-4a21-b3c9-1e4e8a392635
Traceback (most recent call last):
File "/opt/airflow/airflow/api_internal/endpoints/rpc_api_endpoint.py",
line 231, in internal_airflow_api
output = handler(**params, session=session)
File "/opt/airflow/airflow/api_internal/internal_api_call.py", line 135,
in wrapper
return func(*args, **kwargs)
File "/opt/airflow/airflow/utils/session.py", line 94, in wrapper
return func(*args, **kwargs)
File "/opt/airflow/airflow/models/taskinstance.py", line 2737, in
_check_and_change_state_before_execution
task_instance.task = dag.task_dict[ti.task_id]
AttributeError: 'NoneType' object has no attribute 'task_dict'
```
I saw this pr #41082 added some session.commits but I don't think that was
enough. I am trying to look a bit more on what I could do. I tried tinkering
around in conftest.py's init and create_dagrun methods but that didn't do much.
Will see if I can find anything more. @potiuk if you have any directions you
think might be good to look at do let me know.
--
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]
