fxreader.online/freelance-project-34-marketing-blog
2
0
Fork 0
Code Issues 2 Pull Requests Actions Packages Projects Releases Wiki Activity

[+] fix typing

Browse Source
This commit is contained in:
Siarhei Siniak 2025-07-16 10:52:37 +03:00
parent dda9c841fd
commit 17bfb08e43
2 changed files with 7 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
deps/test-task-2025-06-30-v1/python/online/fxreader/pr34/test_task_2025_06_30_v1/async_api/websocket_api.py vendored
View File

@ -63,8 +63,8 @@ class WebsocketAPI:
message=dict( message=dict(
points=[ points=[
dict( dict(
asset_name=o.asset_name, asset_name=o.market.name,
asset_id=o.asset_id, asset_id=o.market.id,
time=o.timestamp.timestamp(), time=o.timestamp.timestamp(),
value=o.value, value=o.value,
) )

10
deps/test-task-2025-06-30-v1/python/online/fxreader/pr34/test_task_2025_06_30_v1/tickers/logic.py vendored
View File

@ -2,8 +2,8 @@ import datetime
from sqlalchemy.ext.asyncio import AsyncSession from sqlalchemy.ext.asyncio import AsyncSession
from sqlalchemy.ext.asyncio import async_sessionmaker from sqlalchemy.ext.asyncio import async_sessionmaker
from sqlalchemy.orm import selectinload from sqlalchemy.orm import selectinload, make_transient
from sqlalchemy.future import select, make_transient from sqlalchemy.future import select
from .models import Ticker, Market from .models import Ticker, Market
from .utils import get_or_create from .utils import get_or_create
@ -44,8 +44,8 @@ async def tickers_get_by_period(
async with session() as active_session: async with session() as active_session:
async with active_session.begin() as transaction: async with active_session.begin() as transaction:
q = select( q = select(
Ticket Ticker
).join(Ticket.market).where( ).join(Ticker.market).where(
Market.id == market_id, Market.id == market_id,
Ticker.timestamp >= datetime.datetime.now( Ticker.timestamp >= datetime.datetime.now(
tz=datetime.timezone.utc tz=datetime.timezone.utc
@ -56,7 +56,7 @@ async def tickers_get_by_period(
res = await active_session.execute(q) res = await active_session.execute(q)
rows = list(res) rows = [o[0] for o in res]
for o in rows: for o in rows:
active_session.expunge(o) active_session.expunge(o)