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

moved commit_session out of heart beat interval

pull/618/head
Yhtyyar Sahatov 2022-05-26 17:19:48 +03:00
rodzic 5dc7716343
commit d25b4d6866
1 zmienionych plików z 3 dodań i 2 usunięć
Pokaż statystyki Ściągnij plik aktualizacji Ściągnij plik porównania Expand all files Collapse all files

5
crawlers/mooncrawl/mooncrawl/moonworm_crawler/continuous_crawler.py
Wyświetl plik

@ -232,6 +232,9 @@ def continuous_crawler(
db_session, all_function_calls, blockchain_type db_session, all_function_calls, blockchain_type
) )
# Commiting to db
commit_session(db_session)
current_time = datetime.utcnow() current_time = datetime.utcnow()
if current_time - jobs_refetchet_time > timedelta( if current_time - jobs_refetchet_time > timedelta(
@ -248,8 +251,6 @@ def continuous_crawler(
if current_time - last_heartbeat_time > timedelta( if current_time - last_heartbeat_time > timedelta(
seconds=heartbeat_interval seconds=heartbeat_interval
): ):
# Commiting to db
commit_session(db_session)
# Update heartbeat # Update heartbeat
heartbeat_template["last_block"] = end_block heartbeat_template["last_block"] = end_block