[GitHub] [airflow] kristoffern commented on pull request #19769: Handle stuck queued tasks in Celery for db backend

[GitBox <gi...@apache.org>]

kristoffern commented on pull request #19769:
URL: https://github.com/apache/airflow/pull/19769#issuecomment-1025734470


   @ephraimbuddy I'm trying to test the patch locally, and I'm sure I'm doing something wrong, but after the cluster is deployed the scheduler crashes with the following error.
   
   ```
   file "/home/airflow/.local/lib/python3.8/site-packages/airflow/executors/celery_executor.py", line 54, in <module>
       from airflow.utils.session import NEW_SESSION, provide_session
   ImportError: cannot import name 'NEW_SESSION' from 'airflow.utils.session' (/home/airflow/.local/lib/python3.8/site-packages/airflow/utils/session.py)
   ```
   
   I've looked in this PR and can't find the NEW_SESSION in the files changed, and I also can't find it in Airflows main branch.
   I don't think I have access to the "astronomer:fix-stuck-task" repo/branch so I can't provide more details unfortunately.
   
   Am I missing something, or was something missedin the PR?
   
   I'm downloading this patch and applying it in my Dockerfile, I can provide the details if you want to.
   
   https://patch-diff.githubusercontent.com/raw/apache/airflow/pull/19769.patch


-- 
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: commits-unsubscribe@airflow.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org