Merge pull request #254 from HSF/dev

use bulk_mapping_update by default
HSF · Nov 29, 2023 · 24f39f1 · 24f39f1
2 parents 18acab8 + e8d1c3a
commit 24f39f1
Show file tree

Hide file tree

Showing 3 changed files with 4 additions and 4 deletions.
diff --git a/main/lib/idds/core/catalog.py b/main/lib/idds/core/catalog.py
@@ -261,7 +261,7 @@ def update_input_collection_with_contents(coll, parameters, contents, bulk_size=
 
 
 @transactional_session
-def update_contents(parameters, request_id=None, transform_id=None, use_bulk_update_mappings=False, session=None):
+def update_contents(parameters, request_id=None, transform_id=None, use_bulk_update_mappings=True, session=None):
     """
     updatecontents.
 
@@ -764,7 +764,7 @@ def add_contents_ext(contents, bulk_size=10000, session=None):
 
 
 @transactional_session
-def update_contents_ext(parameters, request_id=None, transform_id=None, use_bulk_update_mappings=False, session=None):
+def update_contents_ext(parameters, request_id=None, transform_id=None, use_bulk_update_mappings=True, session=None):
     """
     update contents ext.
 

diff --git a/main/lib/idds/core/processings.py b/main/lib/idds/core/processings.py
@@ -318,7 +318,7 @@ def update_processing_contents(update_processing, update_contents=None, update_m
                                update_dep_contents=None, update_collections=None, messages=None,
                                new_update_contents=None, new_input_dependency_contents=None,
                                new_contents_ext=None, update_contents_ext=None,
-                               request_id=None, transform_id=None, use_bulk_update_mappings=False,
+                               request_id=None, transform_id=None, use_bulk_update_mappings=True,
                                message_bulk_size=2000, session=None):
     """
     Update processing with contents.

diff --git a/main/lib/idds/orm/contents.py b/main/lib/idds/orm/contents.py
@@ -473,7 +473,7 @@ def update_content(content_id, parameters, session=None):
 
 
 @transactional_session
-def update_contents(parameters, use_bulk_update_mappings=False, request_id=None, transform_id=None, session=None):
+def update_contents(parameters, use_bulk_update_mappings=True, request_id=None, transform_id=None, session=None):
     """
     update contents.