Skip to content

Commit 09e0011

Browse files
committed
Only instanciate one task in asset decorator
1 parent d10109d commit 09e0011

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

task-sdk/src/airflow/sdk/definitions/asset/decorators.py

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -107,8 +107,8 @@ def _instantiate_task(definition: AssetDefinition | MultiAssetDefinition) -> Non
107107

108108
decorated_operator.kwargs["outlets"] = [v for _, v in definition.iter_assets()]
109109
decorated_operator()
110-
111-
_AssetMainOperator.from_definition(definition)
110+
else:
111+
_AssetMainOperator.from_definition(definition)
112112

113113

114114
@attrs.define(kw_only=True)

0 commit comments

Comments
 (0)