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 2020/08/09 03:20:58 UTC

[GitHub] [airflow] chenzuoli commented on issue #10155: Airflow 1.10.10 + DAG SERIALIZATION = fails to start manually the DAG's operators

chenzuoli commented on issue #10155:
URL: https://github.com/apache/airflow/issues/10155#issuecomment-671000423


   I get this error too, and fix it:
   vim airflow/serialization/serialized_objects.py +582
   replace:
   `dag.task_dict[task_id]._upstream_task_ids.add(task_id)`  # pylint: disable=protected-access`
   to 
   `dag.task_dict[task_id]._upstream_task_ids.add(task.task_id)  # pylint: disable=protected-access`
   because the operator get the wrong upstream_task_ids, just add the right upstream task id,and works fine.


----------------------------------------------------------------
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:
users@infra.apache.org