Database: Restrict index creation to one worker.

CESNET · Jul 12, 2024 · fed2dad · fed2dad
1 parent c00b8bf
commit fed2dad
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/dp3/database/database.py b/dp3/database/database.py
@@ -125,7 +125,8 @@ def __init__(
 
         # Init and switch to correct database
         self._db = self._db[config.db_name]
-        self._init_database_schema(config.db_name)
+        if process_index == 0:
+            self._init_database_schema(config.db_name)
 
         self.schema_cleaner = SchemaCleaner(
             self._db, self.get_module_cache("Schema"), self._db_schema_config, self.log