Skip to content

Commit 079a762

Browse files
committed
Fix timestamp issue with PGSQL
1 parent de08d58 commit 079a762

File tree

3 files changed

+5
-4
lines changed

3 files changed

+5
-4
lines changed

fastapi_users_db_sqlalchemy/__init__.py

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -154,7 +154,6 @@ async def add_oauth_account(self, user: UP, create_dict: Dict[str, Any]) -> UP:
154154
self.session.add(user)
155155

156156
await self.session.commit()
157-
await self.session.refresh(user)
158157

159158
return user
160159

@@ -168,7 +167,7 @@ async def update_oauth_account(
168167
setattr(oauth_account, key, value)
169168
self.session.add(oauth_account)
170169
await self.session.commit()
171-
await self.session.refresh(user)
170+
172171
return user
173172

174173
async def _get_user(self, statement: Select) -> Optional[UP]:

fastapi_users_db_sqlalchemy/access_token.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -24,7 +24,7 @@ class SQLAlchemyBaseAccessTokenTable(Generic[ID]):
2424
else:
2525
token: str = Column(String(length=43), primary_key=True)
2626
created_at: datetime = Column(
27-
TIMESTAMPAware, index=True, nullable=False, default=now_utc
27+
TIMESTAMPAware(timezone=True), index=True, nullable=False, default=now_utc
2828
)
2929

3030

tests/test_access_token.py

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -76,7 +76,9 @@ async def test_queries(
7676
updated_access_token = await sqlalchemy_access_token_db.update(
7777
access_token, update_dict
7878
)
79-
assert updated_access_token.created_at == update_dict["created_at"]
79+
assert updated_access_token.created_at.replace(microsecond=0) == update_dict[
80+
"created_at"
81+
].replace(microsecond=0)
8082

8183
# Get by token
8284
access_token_by_token = await sqlalchemy_access_token_db.get_by_token(

0 commit comments

Comments
 (0)