Skip to content

Commit a7e4dcc

Browse files
committed
fixup! test: fix tests
1 parent 183346b commit a7e4dcc

1 file changed

Lines changed: 2 additions & 3 deletions

File tree

airflow/decorators/assets.py

Lines changed: 2 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -50,10 +50,9 @@ def _iter_kwargs(self, context: Mapping[str, Any]) -> Iterator[tuple[str, Any]]:
5050
key = "_self"
5151
value = self._active_assets.get(self._definition_name)
5252
if not value:
53-
asset_args = {"name": self._definition_name}
53+
value = Asset(name=self._definition_name)
5454
if self._uri is not None:
55-
asset_args = {"uri": self._uri}
56-
value = Asset(**asset_args)
55+
value.uri = self._uri
5756
elif key == "context":
5857
value = context
5958
else:

0 commit comments

Comments
 (0)