lfreina commented on issue #13542:
URL: https://github.com/apache/airflow/issues/13542#issuecomment-849769325
I am having more or less the same issue with Kubernetes Executor. I sent the
SIGUSR2 to the scheduler and got this:
```
[2021-05-27 16:15:55,628] {kubernetes_executor.py:208} INFO - Event:
tutorialtestrunthisfirst.ef1f345cc84b46beb4863e1e1a6121f8 is Running
[2021-05-27 16:19:15,850] {scheduler_job.py:759} INFO -
--------------------------------------------------------------------------------
SIGUSR2 received, printing debug
--------------------------------------------------------------------------------
[2021-05-27 16:19:15,851] {base_executor.py:305} INFO - executor.queued (0)
[2021-05-27 16:19:15,851] {base_executor.py:307} INFO - executor.running (2)
TaskInstanceKey(dag_id='tutorial_test', task_id='run_this_first',
execution_date=datetime.datetime(2021, 5, 26, 4, 0, tzinfo=Timezone('UTC')),
try_number=1)
TaskInstanceKey(dag_id='hello_world', task_id='hello_task',
execution_date=datetime.datetime(2021, 5, 26, 12, 0, tzinfo=Timezone('UTC')),
try_number=1)
[2021-05-27 16:19:15,851] {base_executor.py:311} INFO -
executor.event_buffer (0)
[2021-05-27 16:19:15,851] {scheduler_job.py:762} INFO -
--------------------------------------------------------------------------------
```
Not much info there. I am using a simple DAG here. The task just gets stuck
in queued state but nothing happens. Maybe I am doing something wrong but no
error is shown and this might point out the problem we are all experiencing
here.
```
from datetime import datetime
from airflow import DAG
# For airflow 2.1.0
from airflow.operators.python import PythonOperator
from airflow.operators.dummy import DummyOperator
# For airflow 1.10.10
#from airflow.operators.dummy_operator import DummyOperator
#from airflow.operators.python_operator import PythonOperator
def print_hello(**kwargs):
return 'Hello world!'
def print_goodbye(**kwargs):
return 'Goodbye world'
dag = DAG('hello_world', description='Simple tutorial DAG',
schedule_interval='0 12 * * *',
start_date=datetime(2021, 3, 20),
catchup=False)
dummy_operator = DummyOperator(task_id='dummy_task', retries=3, dag=dag)
hello_operator = PythonOperator(task_id='hello_task',
python_callable=print_hello, dag=dag)
goodbye_operator = PythonOperator(task_id='print_goodbye',
python_callable=print_goodbye, dag=dag)
dummy_operator >> hello_operator >> goodbye_operator
```
I did test this DAG in minikube in a similar setup as I did for issue
#15305. This DAG works with airflow 1.10.10 but does not with 2.1.0.
--
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]
