Skip to content
Snippets Groups Projects
Commit ad4882dd authored by Alexander Schlemmer's avatar Alexander Schlemmer
Browse files

STY: removed some minor style issues

parent 2fcd06b3
No related branches found
No related tags found
2 merge requests!178FIX: #96 Better error output for crawl.py script.,!167Sync Graph
Pipeline #51536 passed with warnings
...@@ -336,7 +336,7 @@ class Crawler(object): ...@@ -336,7 +336,7 @@ class Crawler(object):
# ) # )
raise RuntimeError( raise RuntimeError(
f"Could not finish split_into_inserts_and_updates. " "Could not finish split_into_inserts_and_updates. "
"It might be due to a circular dependency") "It might be due to a circular dependency")
return st.export_record_lists() return st.export_record_lists()
...@@ -692,14 +692,14 @@ class Crawler(object): ...@@ -692,14 +692,14 @@ class Crawler(object):
cache_clear() cache_clear()
self.execute_parent_updates_in_list(to_be_updated, securityMode=self.securityMode, self.execute_parent_updates_in_list(to_be_updated, securityMode=self.securityMode,
run_id=self.run_id, unique_names=unique_names) run_id=self.run_id, unique_names=unique_names)
logger.info(f"Added parent RecordTypes where necessary.") logger.info("Added parent RecordTypes where necessary.")
self.execute_inserts_in_list( self.execute_inserts_in_list(
to_be_inserted, self.securityMode, self.run_id, unique_names=unique_names) to_be_inserted, self.securityMode, self.run_id, unique_names=unique_names)
logger.info(f"Executed inserts:\n" logger.info("Executed inserts:\n"
+ self.create_entity_summary(to_be_inserted)) + self.create_entity_summary(to_be_inserted))
self.execute_updates_in_list( self.execute_updates_in_list(
to_be_updated, self.securityMode, self.run_id, unique_names=unique_names) to_be_updated, self.securityMode, self.run_id, unique_names=unique_names)
logger.info(f"Executed updates:\n" logger.info("Executed updates:\n"
+ self.create_entity_summary(to_be_updated)) + self.create_entity_summary(to_be_updated))
update_cache = UpdateCache() update_cache = UpdateCache()
...@@ -832,13 +832,13 @@ def _update_status_record(run_id, n_inserts, n_updates, status): ...@@ -832,13 +832,13 @@ def _update_status_record(run_id, n_inserts, n_updates, status):
cr_rec.get_property('status').value = status cr_rec.get_property('status').value = status
(cr_rec (cr_rec
.add_property(db.execute_query( .add_property(db.execute_query(
f"FIND Property with name='number_of_inserted_entities'", unique=True).id, "FIND Property with name='number_of_inserted_entities'", unique=True).id,
n_inserts) n_inserts)
.add_property( .add_property(
db.execute_query(f"FIND Property with name='number_of_updated_entities'", db.execute_query("FIND Property with name='number_of_updated_entities'",
unique=True).id, n_updates) unique=True).id, n_updates)
.add_property( .add_property(
db.execute_query(f"FIND Property with name='finished'", db.execute_query("FIND Property with name='finished'",
unique=True).id, datetime.now().isoformat())) unique=True).id, datetime.now().isoformat()))
cr_rec.update() cr_rec.update()
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment