hafid-d edited a comment on issue #15978:
URL: https://github.com/apache/airflow/issues/15978#issuecomment-846780822


   @ephraimbuddy Below are some other logs 
   ```
   [2021-05-24 14:09:18,552] {scheduler_job.py:1006} INFO - DAG *** has 32/32 
running and queued tasks
   [2021-05-24 14:09:18,552] {scheduler_job.py:1014} INFO - Not executing 
<TaskInstance: **** 2021-05-24 05:45:57.736363+00:00 [scheduled]> since the 
number of tasks running or queued from DAG **** is >= to the DAG's
   task concurrency limit of 32
   
   ```
   
   I even cleared the Queued slots but everytime I rerun the dag, the tasks 
keep being there with the "queued" state just after the DagBag has been up :
   
   ```
   [2021-05-24 14:14:31,486] {dagbag.py:451} INFO - Filling up the DagBag from 
/home/******.py
   [2021-05-24 14:14:31,490] {dagbag.py:451} INFO - Filling up the DagBag from 
/home/******.py
   [2021-05-24 14:14:31,498] {dagbag.py:451} INFO - Filling up the DagBag from 
/home/******.py
   [2021-05-24 14:14:31,505] {dagbag.py:451} INFO - Filling up the DagBag from 
/home/******.py
   [2021-05-24 14:14:31,502] {dagbag.py:451} INFO - Filling up the DagBag from 
/home/******.py
   [2021-05-24 14:14:31,508] {dagbag.py:451} INFO - Filling up the DagBag from 
/home/******.py
   [2021-05-24 14:14:31,510] {dagbag.py:451} INFO - Filling up the DagBag from 
/home/******.py
   [2021-05-24 14:14:31,512] {dagbag.py:451} INFO - Filling up the DagBag from 
/home/******.py
   [2021-05-24 14:14:31,522] {dagbag.py:451} INFO - Filling up the DagBag from 
/home/******.py
   [2021-05-24 14:14:31,527] {dagbag.py:451} INFO - Filling up the DagBag from 
/home/******.py
   [2021-05-24 14:14:31,528] {dagbag.py:451} INFO - Filling up the DagBag from 
/home/******.py
   [2021-05-24 14:14:31,530] {dagbag.py:451} INFO - Filling up the DagBag from 
/home/******.py
   [2021-05-24 14:14:31,538] {dagbag.py:451} INFO - Filling up the DagBag from 
/home/******.py
   [2021-05-24 14:14:31,540] {dagbag.py:451} INFO - Filling up the DagBag from 
/home/******.py
   [2021-05-24 14:14:31,542] {dagbag.py:451} INFO - Filling up the DagBag from 
/home/******.py
   [2021-05-24 14:14:31,542] {dagbag.py:451} INFO - Filling up the DagBag from 
/home/******.py
   [2021-05-24 14:14:31,546] {dagbag.py:451} INFO - Filling up the DagBag from 
/home/******.py
   [2021-05-24 14:14:31,570] {dagbag.py:451} INFO - Filling up the DagBag from 
/home/******.py
   [2021-05-24 14:14:31,578] {dagbag.py:451} INFO - Filling up the DagBag from 
/home/******.py
   [2021-05-24 14:14:31,598] {dagbag.py:451} INFO - Filling up the DagBag from 
/home/******.py
   [2021-05-24 14:14:31,630] {dagbag.py:451} INFO - Filling up the DagBag from 
/home/******.py
   [2021-05-24 14:14:31,642] {dagbag.py:451} INFO - Filling up the DagBag from 
/home/******.py
   [2021-05-24 14:14:31,658] {dagbag.py:451} INFO - Filling up the DagBag from 
/home/******.py
   [2021-05-24 14:14:55,551: WARNING/ForkPoolWorker-16] Running <TaskInstance: 
*****A1 2021-05-24T06:14:30.718313+00:00 [queued]> on host **********
   [2021-05-24 14:14:55,861: WARNING/ForkPoolWorker-13] Running <TaskInstance: 
***** 2021-05-24T06:14:30.718313+00:00 [queued]> on host **********
   [2021-05-24 14:14:56,321: WARNING/ForkPoolWorker-22] Running <TaskInstance: 
***** 2021-05-24T06:14:30.718313+00:00 [queued]> on host **********
   [2021-05-24 14:14:56,361: WARNING/ForkPoolWorker-32] Running <TaskInstance: 
***** 2021-05-24T06:14:30.718313+00:00 [queued]> on host **********
   [2021-05-24 14:14:56,363: WARNING/ForkPoolWorker-7] Running <TaskInstance: 
***** 2021-05-24T06:14:30.718313+00:00 [queued]> on host **********
   [2021-05-24 14:14:56,388: WARNING/ForkPoolWorker-20] Running <TaskInstance: 
***** 2021-05-24T06:14:30.718313+00:00 [queued]> on host **********
   [2021-05-24 14:14:56,402: WARNING/ForkPoolWorker-24] Running <TaskInstance: 
***** 2021-05-24T06:14:30.718313+00:00 [queued]> on host **********
   [2021-05-24 14:14:56,416: WARNING/ForkPoolWorker-25] Running <TaskInstance: 
***** 2021-05-24T06:14:30.718313+00:00 [queued]> on host **********
   [2021-05-24 14:14:56,428: WARNING/ForkPoolWorker-4] Running <TaskInstance: 
***** 2021-05-24T06:14:30.718313+00:00 [queued]> on host **********
   [2021-05-24 14:14:56,474: WARNING/ForkPoolWorker-6] Running <TaskInstance: 
***** 2021-05-24T06:14:30.718313+00:00 [queued]> on host **********
   [2021-05-24 14:14:56,484: WARNING/ForkPoolWorker-11] Running <TaskInstance: 
***** 2021-05-24T06:14:30.718313+00:00 [queued]> on host **********
   [2021-05-24 14:14:56,490: WARNING/ForkPoolWorker-17] Running <TaskInstance: 
***** 2021-05-24T06:14:30.718313+00:00 [queued]> on host **********
   [2021-05-24 14:14:56,492: WARNING/ForkPoolWorker-2] Running <TaskInstance: 
***** 2021-05-24T06:14:30.718313+00:00 [queued]> on host **********
   [2021-05-24 14:14:56,570: WARNING/ForkPoolWorker-3] Running <TaskInstance: 
***** 2021-05-24T06:14:30.718313+00:00 [queued]> on host **********
   [2021-05-24 14:14:56,588: WARNING/ForkPoolWorker-30] Running <TaskInstance: 
***** 2021-05-24T06:14:30.718313+00:00 [queued]> on host **********
   [2021-05-24 14:14:56,590: WARNING/ForkPoolWorker-14] Running <TaskInstance: 
***** 2021-05-24T06:14:30.718313+00:00 [queued]> on host **********
   [2021-05-24 14:14:56,598: WARNING/ForkPoolWorker-31] Running <TaskInstance: 
***** 2021-05-24T06:14:30.718313+00:00 [queued]> on host **********
   [2021-05-24 14:14:56,646: WARNING/ForkPoolWorker-12] Running <TaskInstance: 
***** 2021-05-24T06:14:30.718313+00:00 [queued]> on host **********
   [2021-05-24 14:14:56,651: WARNING/ForkPoolWorker-15] Running <TaskInstance: 
***** 2021-05-24T06:14:30.718313+00:00 [queued]> on host **********
   [2021-05-24 14:14:56,679: WARNING/ForkPoolWorker-23] Running <TaskInstance: 
***** 2021-05-24T06:14:30.718313+00:00 [queued]> on host **********
   [2021-05-24 14:14:56,682: WARNING/ForkPoolWorker-21] Running <TaskInstance: 
***** 2021-05-24T06:14:30.718313+00:00 [queued]> on host **********
   [2021-05-24 14:14:56,719: WARNING/ForkPoolWorker-8] Running <TaskInstance: 
***** 2021-05-24T06:14:30.718313+00:00 [queued]> on host **********
   [2021-05-24 14:14:56,722: WARNING/ForkPoolWorker-18] Running <TaskInstance: 
***** 2021-05-24T06:14:30.718313+00:00 [queued]> on host **********
   [2021-05-24 14:14:56,742: WARNING/ForkPoolWorker-26] Running <TaskInstance: 
***** 2021-05-24T06:14:30.718313+00:00 [queued]> on host **********
   [2021-05-24 14:14:56,754: WARNING/ForkPoolWorker-28] Running <TaskInstance: 
*****A1 2021-05-24T06:14:30.718313+00:00 [queued]> on host **********
   [2021-05-24 14:14:56,777: WARNING/ForkPoolWorker-29] Running <TaskInstance: 
*****A2 2021-05-24T06:14:30.718313+00:00 [queued]> on host **********
   [2021-05-24 14:14:56,832: WARNING/ForkPoolWorker-9] Running <TaskInstance: 
***** 2021-05-24T06:14:30.718313+00:00 [queued]> on host **********
   [2021-05-24 14:14:56,846: WARNING/ForkPoolWorker-5] Running <TaskInstance: 
***** 2021-05-24T06:14:30.718313+00:00 [queued]> on host **********
   [2021-05-24 14:14:56,857: WARNING/ForkPoolWorker-19] Running <TaskInstance: 
***** 2021-05-24T06:14:30.718313+00:00 [queued]> on host **********
   [2021-05-24 14:14:56,898: WARNING/ForkPoolWorker-27] Running <TaskInstance: 
***** 2021-05-24T06:14:30.718313+00:00 [queued]> on host **********
   [2021-05-24 14:14:56,900: WARNING/ForkPoolWorker-10] Running <TaskInstance: 
***** 2021-05-24T06:14:30.718313+00:00 [queued]> on host **********
   [2021-05-24 14:14:56,929: WARNING/ForkPoolWorker-1] Running <TaskInstance: 
***** 2021-05-24T06:14:30.718313+00:00 [queued]> on host **********
   
   ```
   
   
   
   
   


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