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