Skip to content

Commit 8f8171f

Browse files
committed
fix: query events detect
1 parent 82b12ff commit 8f8171f

2 files changed

Lines changed: 4 additions & 4 deletions

File tree

event_worker/src/event/repository.py

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -35,9 +35,9 @@ async def scan_event(self) -> list[Row]:
3535
AND m.finish_date >= :now
3636
AND r.is_active = true
3737
AND (
38-
CASE WHEN :start_time <= :end_time
39-
THEN r.reception_time BETWEEN :start_time AND :end_time
40-
ELSE r.reception_time >= :start_time OR r.reception_time <= :end_time
38+
CASE WHEN CAST(:start_time AS time) <= CAST(:end_time AS time)
39+
THEN r.reception_time BETWEEN CAST(:start_time AS time) AND CAST(:end_time AS time)
40+
ELSE r.reception_time >= CAST(:start_time AS time) OR r.reception_time <= CAST(:end_time AS time)
4141
END
4242
);
4343
""")

event_worker/src/settings/database.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -3,7 +3,7 @@
33
from sqlalchemy.engine.url import URL
44
from sqlalchemy.ext.asyncio import AsyncEngine, AsyncSession, async_sessionmaker
55
from sqlalchemy.ext.asyncio import create_async_engine as _create_async_engine
6-
from api_backend.settings.configuration import config_project
6+
from src.settings.configuration import config_project
77

88

99
def create_async_engine(url: URL | str) -> AsyncEngine:

0 commit comments

Comments
 (0)