In the graded assignment Building an Advanced Data Pipeline With Data Quality Checks
When I am uploading the the dag files, the airflow is showing following error:
Broken DAG: [/opt/airflow/dags/model_trip_duration_alitran.py]
Traceback (most recent call last):
File “/home/airflow/.local/lib/python3.11/site-packages/airflow/models/taskmixin.py”, line 263, in set_downstream
self._set_relatives(task_or_task_list, upstream=False, edge_modifier=edge_modifier)
File “/home/airflow/.local/lib/python3.11/site-packages/airflow/models/taskmixin.py”, line 215, in _set_relatives
task_object.update_relative(self, not upstream, edge_modifier=edge_modifier)
^^^^^^^^^^^^^^^^^^^^^^^^^^^
AttributeError: ‘function’ object has no attribute ‘update_relative’
This is happening for all the 3 dag files.
- model_trip_duration_alitran:
- model_trip_duration_easy_destiny:
- model_trip_duration_to_my_place_ai