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