From 4e021ace318cdd8528b581ccc97c2881dbee2c57 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?Henrik=20tom=20W=C3=B6rden?= <h.tomwoerden@indiscale.com>
Date: Fri, 21 Mar 2025 16:06:07 +0100
Subject: [PATCH] REFACTOR: use more cached queries
---
src/caoscrawler/crawl.py | 11 ++++-------
1 file changed, 4 insertions(+), 7 deletions(-)
diff --git a/src/caoscrawler/crawl.py b/src/caoscrawler/crawl.py
index e0d24397..3d1e9f75 100644
--- a/src/caoscrawler/crawl.py
+++ b/src/caoscrawler/crawl.py
@@ -873,15 +873,12 @@ def _update_status_record(run_id, n_inserts, n_updates, status):
cr_rec = db.execute_query(f"FIND RECORD CrawlerRun WITH run_id={run_id}", unique=True)
cr_rec.get_property('status').value = status
(cr_rec
- .add_property(db.execute_query(
- "FIND Property with name='number_of_inserted_entities'", unique=True).id,
- n_inserts)
.add_property(
- db.execute_query("FIND Property with name='number_of_updated_entities'",
- unique=True).id, n_updates)
+ cached_get_entity_by(name='number_of_inserted_entities').id, n_inserts)
.add_property(
- db.execute_query("FIND Property with name='finished'",
- unique=True).id, datetime.now().isoformat()))
+ cached_get_entity_by(name='number_of_updated_entities').id, n_updates)
+ .add_property(
+ cached_get_entity_by(name='finished').id, datetime.now().isoformat()))
cr_rec.update()
--
GitLab