fix(ingest/airflow): make inlets work again (#8631)

This commit is contained in:
Harshal Sheth 2023-08-15 05:42:43 -07:00 committed by GitHub
parent ddcd5109dc
commit 9eb432cda0
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23

View File

@ -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