Hi, I'm not an Airflow expert and I've not had time to test this myself but poking around in the code it appears BaseOperator has a new parameter "do_xcom_push": https://github.com/apache/airflow/blob/master/airflow/models/baseoperator.py
Whereas the old BaseOperator did not have this: https://github.com/apache/airflow/blob/16d93c9e45e14179c7822fed248743f0c3fd935c/airflow/models/__init__.py#L1938 As all Operators and Sensors inherit from BaseOperator it would appear your DummyOperator object is coming from Airflow 1.10.3 or lower environment but you're running it in an Airflow 1.10.4 environment. Could this be the case? Da,oam -----Original Message----- From: Frank Maritato [mailto:[email protected]] Sent: Wednesday, August 07, 2019 12:27 PM To: [email protected] Subject: DummyOperator error in 1.10.4 Hi All, I'm testing my dags in airflow 1.10.4 and I ran across this error: [2019-08-07 16:13:09,712] {taskinstance.py:1047} ERROR - 'DummyOperator' object has no attribute 'do_xcom_push' Traceback (most recent call last): File "/opt/conda/lib/python3.7/site-packages/airflow/models/taskinstance.py", line 925, in _run_raw_task if task_copy.do_xcom_push and result is not None: AttributeError: 'DummyOperator' object has no attribute 'do_xcom_push' [2019-08-07 16:13:09,713] {taskinstance.py:1078} INFO - Marking task as FAILED. Is this a misconfiguration on my side? This definitely worked in 1.10.3 start = DummyOperator( dag=dag, task_id='process_start' ) Also, a note, I had to explicitly add werkzeug==0.15.0 to my docker container requirements.txt file in order for 1.10.4 to work at all. Thanks! -- Frank Maritato =============================================================================== Please access the attached hyperlink for an important electronic communications disclaimer: http://www.credit-suisse.com/legal/en/disclaimer_email_ib.html ===============================================================================
