Skip to content

Commit d9539ea

Browse files
yoeoLee-W
authored andcommitted
Only instanciate one task in asset decorator
1 parent 4bb67f4 commit d9539ea

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
@@ -105,8 +105,8 @@ def _instantiate_task(definition: AssetDefinition | MultiAssetDefinition) -> Non
105105

106106
decorated_operator.kwargs["outlets"] = [v for _, v in definition.iter_assets()]
107107
decorated_operator()
108-
109-
_AssetMainOperator.from_definition(definition)
108+
else:
109+
_AssetMainOperator.from_definition(definition)
110110

111111

112112
@attrs.define(kw_only=True)

0 commit comments

Comments
 (0)