You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@airflow.apache.org by GitBox <gi...@apache.org> on 2021/10/19 14:44:28 UTC
[GitHub] [airflow] jedcunningham commented on issue #19069: 2.2 Pythonoperator The task executed successfully, but was not marked as successful, resulting in increasing memory and eventually outage
jedcunningham commented on issue #19069:
URL: https://github.com/apache/airflow/issues/19069#issuecomment-946797650
Hi @lanms, I'm not able to reproduce this and I suspect it's something related to `EnterpriseWeiChat`. Can you try to reproduce with this DAG:
```python
from datetime import datetime
from airflow import DAG
from airflow.operators.python import PythonOperator, ShortCircuitOperator
def say_hello():
print("hello")
def keep_going():
return True
with DAG("pythonop", start_date=datetime(2021, 10, 14), schedule_interval=None) as dag:
short = ShortCircuitOperator(task_id="short", python_callable=keep_going)
hello = PythonOperator(task_id="hello", python_callable=say_hello)
short >> hello
```
--
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