Skip to content
Snippets Groups Projects

Merge parents caches into the current task one

Merged Eva Bardou requested to merge merge-parents-cache into master
All threads resolved!
3 files
+ 78
12
Compare changes
  • Side-by-side
  • Inline
Files
3
+ 9
9
@@ -102,13 +102,15 @@ def merge_parents_cache(parent_ids, current_database, data_dir="/data", chunk=No
filenames.append(f"db_{chunk}.sqlite")
# Find all the paths for these databases
paths = filter(
lambda p: os.path.isfile(p),
[
os.path.join(data_dir, parent, name)
for parent in parent_ids
for name in filenames
],
paths = list(
filter(
lambda p: os.path.isfile(p),
[
os.path.join(data_dir, parent, name)
for parent in parent_ids
for name in filenames
],
)
)
if not paths:
@@ -133,5 +135,3 @@ def merge_parents_cache(parent_ids, current_database, data_dir="/data", chunk=No
for statement in statements:
cursor.execute(statement)
connection.commit()
# TODO: maybe reopen peewee connection ?
Loading