Skip to content
Snippets Groups Projects

Add Version table in SQLite cache + Check compatibility from tasks

Merged Eva Bardou requested to merge version-in-cache-db into master
All threads resolved!
6 files
+ 197
5
Compare changes
  • Side-by-side
  • Inline
Files
6
@@ -19,7 +19,9 @@ from tenacity import (
from arkindex import ArkindexClient, options_from_env
from arkindex_worker import logger
from arkindex_worker.cache import (
check_version,
create_tables,
create_version_table,
init_cache_db,
merge_parents_cache,
retrieve_parents_cache_path,
@@ -203,6 +205,12 @@ class BaseWorker(object):
self.cache_path = os.path.join(cache_dir, "db.sqlite")
init_cache_db(self.cache_path)
if self.args.database is not None:
check_version(self.cache_path)
else:
create_version_table()
create_tables()
# Merging parents caches (if there are any) in the current task local cache, unless the database got overridden
Loading