diff --git a/main.py b/main.py
index 6c134e8..a84d2e6 100644
--- a/main.py
+++ b/main.py
@@ -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
 
diff --git a/src/backend/backend_main.py b/src/backend/backend_main.py
index 0e5003c..bf063fd 100644
--- a/src/backend/backend_main.py
+++ b/src/backend/backend_main.py
@@ -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