Commit 2b2682d 1 parent 4ac8a7b commit 2b2682d Copy full SHA for 2b2682d
File tree 1 file changed +2
-2
lines changed
metadata-ingestion-modules/airflow-plugin/src/datahub_airflow_plugin
1 file changed +2
-2
lines changed Original file line number Diff line number Diff line change @@ -46,7 +46,7 @@ def get_task_inlets(operator: "Operator") -> List:
46
46
return operator ._inlets # type: ignore[attr-defined, union-attr]
47
47
if hasattr (operator , "get_inlet_defs" ):
48
48
return operator .get_inlet_defs () # type: ignore[attr-defined]
49
- return operator .inlets
49
+ return operator .inlets or []
50
50
51
51
52
52
def get_task_outlets (operator : "Operator" ) -> List :
@@ -56,7 +56,7 @@ def get_task_outlets(operator: "Operator") -> List:
56
56
return operator ._outlets # type: ignore[attr-defined, union-attr]
57
57
if hasattr (operator , "get_outlet_defs" ):
58
58
return operator .get_outlet_defs ()
59
- return operator .outlets
59
+ return operator .outlets or []
60
60
61
61
62
62
__all__ = [
You can’t perform that action at this time.
0 commit comments