bolkedebruin commented on a change in pull request #6564: [AIRFLOW-5911] Simplify lineage API and improve robustness URL: https://github.com/apache/airflow/pull/6564#discussion_r349267760
########## File path: airflow/lineage/__init__.py ########## @@ -18,18 +18,25 @@ # under the License. # pylint:disable=missing-docstring +import attr +import jinja2 +import json from functools import wraps -from itertools import chain from airflow.configuration import conf from airflow.exceptions import AirflowConfigException -from airflow.lineage.datasets import DataSet +from airflow.lineage.entity.dataset import Dataset from airflow.utils.log.logging_mixin import LoggingMixin from airflow.utils.module_loading import import_string +from cattr import structure + +ENV = jinja2.Environment() + PIPELINE_OUTLETS = "pipeline_outlets" PIPELINE_INLETS = "pipeline_inlets" +AUTO = "auto" Review comment: How'd you mean? ---------------------------------------------------------------- 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: us...@infra.apache.org With regards, Apache Git Services
