kaxil commented on issue #13811:
URL: https://github.com/apache/airflow/issues/13811#issuecomment-773270707


   Try with the following to delay import and creating a session in the 
mutation hook
   
   ```python
   def task_instance_mutation_hook(task_instance):
       from airflow.settings import Session
       session = Session()
       dag_run = task_instance.get_dagrun(session=session)
       conf = dag_run.conf
   ```


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


Reply via email to