Paritosh Upadhyay commited on
Commit ·
a4277f4
1
Parent(s): 2fd9130
Hotfix: Final migration of Holocron to State central
Browse files
backend/app/services/holocron.py
CHANGED
|
@@ -220,7 +220,7 @@ def batch_mine_priorities():
|
|
| 220 |
def _run_batch():
|
| 221 |
logger.info("Holocron: Initiating Sovereign Priority Ingestion Cycle...")
|
| 222 |
for d in domains:
|
| 223 |
-
if
|
| 224 |
logger.warning("Holocron: Sovereign Termination signal received. Aborting batch cycle.")
|
| 225 |
break
|
| 226 |
_active_foraging_threads.add(d)
|
|
@@ -253,9 +253,9 @@ def _mine_sync(topic: str, depth: int = 1):
|
|
| 253 |
return
|
| 254 |
|
| 255 |
for res in results:
|
| 256 |
-
if
|
| 257 |
-
logger.
|
| 258 |
-
|
| 259 |
url = res.get("href")
|
| 260 |
if url and url not in _processed_urls:
|
| 261 |
try:
|
|
|
|
| 220 |
def _run_batch():
|
| 221 |
logger.info("Holocron: Initiating Sovereign Priority Ingestion Cycle...")
|
| 222 |
for d in domains:
|
| 223 |
+
if _check_halt():
|
| 224 |
logger.warning("Holocron: Sovereign Termination signal received. Aborting batch cycle.")
|
| 225 |
break
|
| 226 |
_active_foraging_threads.add(d)
|
|
|
|
| 253 |
return
|
| 254 |
|
| 255 |
for res in results:
|
| 256 |
+
if _check_halt():
|
| 257 |
+
logger.info("Foraging aborted mid-processing.")
|
| 258 |
+
return
|
| 259 |
url = res.get("href")
|
| 260 |
if url and url not in _processed_urls:
|
| 261 |
try:
|