potiuk commented on a change in pull request #7138: [AIRFLOW-5912] Expose
lineage API
URL: https://github.com/apache/airflow/pull/7138#discussion_r368301113
##########
File path: airflow/api/client/api_client.py
##########
@@ -70,3 +70,12 @@ def delete_pool(self, name):
:param name: pool name
"""
raise NotImplementedError()
+
+ def get_lineage(self, dag_id: str, execution_date: str):
Review comment:
I think for now it's OK to follow the current "experimental" approach and
add this as it is. But we should discuss the approach for API in general soon
and define/agree in community both - our target for API implementation and our
roadmap how we will get there.
For now I think we have no other choice but implement it this way if this is
needed for some other work, but we should be aware it might get deprecated in
case we decide that we replace the experimental API with another approach.
Certainly we should not change the approach before we decide where we are
going.
----------------------------------------------------------------
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:
[email protected]
With regards,
Apache Git Services