diff --git a/src/caoscrawler/crawl.py b/src/caoscrawler/crawl.py index e0d243979faee8f44cdcee3b0e49c15af640c378..3d1e9f754b6de1c8db959be26dc24da1d05e9d16 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()