mirror
/
moonstream
kopia lustrzana https://github.com/bugout-dev/moonstream
1
0
Forkuj 0
Kod Zgłoszenia Projekty Wydania Wiki Aktywność

Fix whale import.

pull/475/head
Andrey Dolgolev 2021-12-02 15:22:48 +02:00
rodzic 5dfcaaeb6e
commit 4308d2e410
1 zmienionych plików z 4 dodań i 4 usunięć
Pokaż statystyki Ściągnij plik aktualizacji Ściągnij plik porównania Expand all files Collapse all files

8
backend/moonstreamapi/routes/whales.py
Wyświetl plik

@ -11,7 +11,7 @@ from moonstreamdb import db
from sqlalchemy.orm import Session from sqlalchemy.orm import Session
from .. import data from .. import data
from ..providers.bugout import whalewatch_provider from ..providers.bugout import ethereum_whalewatch_provider
from ..settings import ( from ..settings import (
bugout_client, bugout_client,
MOONSTREAM_ADMIN_ACCESS_TOKEN, MOONSTREAM_ADMIN_ACCESS_TOKEN,
@ -47,14 +47,14 @@ async def stream_handler(
include_end=include_end, include_end=include_end,
) )
result = whalewatch_provider.get_events( result = ethereum_whalewatch_provider.get_events(
db_session=db_session, db_session=db_session,
bugout_client=bugout_client, bugout_client=bugout_client,
data_journal_id=MOONSTREAM_DATA_JOURNAL_ID, data_journal_id=MOONSTREAM_DATA_JOURNAL_ID,
data_access_token=MOONSTREAM_ADMIN_ACCESS_TOKEN, data_access_token=MOONSTREAM_ADMIN_ACCESS_TOKEN,
stream_boundary=stream_boundary, stream_boundary=stream_boundary,
user_subscriptions={whalewatch_provider.event_type: []}, user_subscriptions={ethereum_whalewatch_provider.event_type: []},
query=StreamQuery(subscription_types=[whalewatch_provider.event_type]), query=StreamQuery(subscription_types=[ethereum_whalewatch_provider.event_type]),
) )
if result is None: if result is None: