Skip to content

Commit 347080d

Browse files
author
meshya
committed
fix: change deprecation warning get_data/get_state calls
1 parent 32bc01a commit 347080d

File tree

1 file changed

+3
-3
lines changed

1 file changed

+3
-3
lines changed

sqlalchemy_storage/storage.py

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -36,7 +36,7 @@ def __init__(
3636
"Passing Base is deprecated. \n"
3737
"Please pass an instance of MetaData instead. \n"
3838
"For example: SQLAlchemyStorage(metadata=Base.metadata) \n",
39-
DeprecationWarning,
39+
UserWarning,
4040
)
4141
metadata = metadata.metadata
4242
if not isinstance(metadata, MetaData):
@@ -97,7 +97,7 @@ async def set_state(self, key: StorageKey, state: StateType = None) -> None:
9797
new_row = self._model(id=pk, state=dump_state, data=None)
9898
session.add(new_row)
9999
if dump_state is None:
100-
data = await self.get_data()
100+
data = await self.get_data(key)
101101
if not data:
102102
await session.execute(
103103
Delete(self._model).where(
@@ -141,7 +141,7 @@ async def set_data(self, key: StorageKey, data: Dict[str, Any]) -> None:
141141
new_row = self._model(id=pk, data=data, state=None)
142142
session.add(new_row)
143143
if not data:
144-
if not await self.get_state():
144+
if not await self.get_state(key):
145145
await session.execute(
146146
Delete(self._model).where(
147147
self._model.id == pk

0 commit comments

Comments
 (0)