Hi, I was using the PythonOperator and was trying to delete a running task. But I figured that even though the task gets removed by the GUI, the subprocess is still running.
I suspect that this is because the on_kill method is not implemented in the PythonOperator [1] Can some one confirm this? Is there any reason, why it is not implemented and what would be the consequences of that being implemented? Best [1] https://github.com/apache/incubator-airflow/blob/master/airflow/operators/python_operator.py Best regards Niranda Perera Research Assistant Dept of CSE, University of Moratuwa [email protected] +94 71 554 8430 https://lk.linkedin.com/in/niranda
