pull/1065/head
Andrey 2024-06-20 21:25:40 +03:00
rodzic 577df99a74
commit 291fd75df6
1 zmienionych plików z 15 dodań i 15 usunięć

Wyświetl plik

@ -523,13 +523,13 @@ def handle_crawl(args: argparse.Namespace) -> None:
else: else:
logger.info("Reading jobs from the journal")
jobs = [] jobs = []
# Bugout # Bugout
query = f"#state_job #blockchain:{blockchain_type.value}" query = f"#state_job #blockchain:{blockchain_type.value}"
print(f"Query: {query}")
existing_jobs = get_all_entries_from_search( existing_jobs = get_all_entries_from_search(
journal_id=MOONSTREAM_STATE_CRAWLER_JOURNAL_ID, journal_id=MOONSTREAM_STATE_CRAWLER_JOURNAL_ID,
search_query=query, search_query=query,