bug fixes

This commit is contained in:
Sai Raj 2024-08-12 21:31:41 -04:00
parent a71c15fe6c
commit 4293c79e63
2 changed files with 2 additions and 1 deletions

View File

@ -4,7 +4,7 @@ import threading
from src.api.api_main import start_api_server
from src.backend.backend_main import start_backend_process
import config as config
from flags import set_run_start
from src.flags import set_run_start
DELAY_API_SERVER_START = 60 # 1 min

View File

@ -589,6 +589,7 @@ def processBlocksInBatch(startIndex, stopIndex, batchsize = BLOCK_SYNC_BATCHSIZE
for j in range(batchsize):
if (i_index <= stopIndex) and (i_index not in IGNORE_BLOCK_LIST):
threads[j] = threading.Thread(target=fetchDataAndStore, args=(i_index, j))
threads[j].start()
i_index += 1 # increment blockindex
# wait for all threads in the batch to complete