WIP test

Author: pcrespov

packages/postgres-database/tests/test_utils_projects.py

@@ -4,19 +4,22 @@
 # pylint: disable=too-many-arguments
 import uuid
 from collections.abc import Awaitable, Callable
-from datetime import datetime
+from datetime import datetime, timezone
 from typing import Any, AsyncIterator
 
 import pytest
 import sqlalchemy
+import sqlalchemy as sa
 from aiopg.sa.connection import SAConnection
 from aiopg.sa.result import RowProxy
 from faker import Faker
+from pydantic import parse_obj_as
 from simcore_postgres_database.models.projects import projects
 from simcore_postgres_database.utils_projects import (
     DBProjectNotFoundError,
     ProjectsRepo,
 )
+from simcore_postgres_database.utils_repos import transaction_context
 from sqlalchemy.ext.asyncio import AsyncEngine
 
 
@@ -51,6 +54,26 @@ async def registered_project(
     await _delete_project(connection, project["uuid"])
 
 
+@pytest.mark.parametrize("expected", (datetime.now(tz=timezone.utc), None))
+async def test_get_project_trashed_at_column_can_be_converted_to_datetime(
+    asyncpg_engine: AsyncEngine, registered_project: dict, expected: datetime | None
+):
+    project_id = registered_project["uuid"]
+
+    async with transaction_context(asyncpg_engine) as conn:
+        result = await conn.execute(
+            projects.update()
+            .values(trashed_at=expected)
+            .where(projects.c.uuid == project_id)
+            .returning(sa.literal_column("*"))
+        )
+
+        row = result.fetchone()
+
+    trashed_at = parse_obj_as(datetime | None, row.trashed_at)
+    assert trashed_at == expected
+
+
 async def test_get_project_last_change_date(
     asyncpg_engine: AsyncEngine, registered_project: dict, faker: Faker
 ):