[GitHub] [airflow] nitinpandey-154 commented on issue #13542: Task stuck in "scheduled" or "queued" state, pool has all slots queued, nothing is executing

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

nitinpandey-154 commented on issue #13542:
URL: https://github.com/apache/airflow/issues/13542#issuecomment-846808019


   Environment:
   - Airflow 2.1.0
   - Docker : apache/airflow:2.1.0-python3.8
   - Executor : Celery
   
   I am facing the same issue again.  This happens randomly and even after cleaning up the tasks instances and/or restarting the container is not fixing the issue.
   
   airflow-scheduler    | [2021-05-24 06:46:52,008] {scheduler_job.py:1105} INFO - Sending TaskInstanceKey(dag_id='airflow_health_checkup', task_id='send_heartbeat', execution_date=datetime.datetime(2021, 5, 24, 4, 21, tzinfo=Timezone('UTC')), try_number=1) to executor with priority 100 and queue airflow_maintenance
   airflow-scheduler    | [2021-05-24 06:46:52,008] {base_executor.py:85} ERROR - could not queue task TaskInstanceKey(dag_id='airflow_health_checkup', task_id='send_heartbeat', execution_date=datetime.datetime(2021, 5, 24, 4, 21, tzinfo=Timezone('UTC')), try_number=1)
   airflow-scheduler    | [2021-05-24 06:46:52,008] {scheduler_job.py:1105} INFO - Sending TaskInstanceKey(dag_id='airflow_health_checkup', task_id='send_heartbeat', execution_date=datetime.datetime(2021, 5, 24, 4, 24, tzinfo=Timezone('UTC')), try_number=1) to executor with priority 100 and queue airflow_maintenance
   airflow-scheduler    | [2021-05-24 06:46:52,009] {base_executor.py:85} ERROR - could not queue task TaskInstanceKey(dag_id='airflow_health_checkup', task_id='send_heartbeat', execution_date=datetime.datetime(2021, 5, 24, 4, 24, tzinfo=Timezone('UTC')), try_number=1)


-- 
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:
users@infra.apache.org