From 9eb432cda07435603b7f2e9f1c2ff9393efca0db Mon Sep 17 00:00:00 2001 From: Harshal Sheth Date: Tue, 15 Aug 2023 05:42:43 -0700 Subject: [PATCH] fix(ingest/airflow): make inlets work again (#8631) --- metadata-ingestion/src/datahub_provider/_plugin.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/metadata-ingestion/src/datahub_provider/_plugin.py b/metadata-ingestion/src/datahub_provider/_plugin.py index 6f6c7c9ab7..ed2e4e1c93 100644 --- a/metadata-ingestion/src/datahub_provider/_plugin.py +++ b/metadata-ingestion/src/datahub_provider/_plugin.py @@ -107,7 +107,7 @@ def get_inlets_from_task(task: BaseOperator, context: Any) -> Iterable[Any]: ] for inlet in task_inlets: - if isinstance(inlet, str): + if not isinstance(inlet, str): inlets.append(inlet) return inlets