@@ -966,9 +966,10 @@ def handle_add_request(
966966 )
967967 # get catalog with opted-in operators
968968 os .makedirs (os .path .join (temp_dir , 'from_index' ), exist_ok = True )
969- catalog_from_index = get_catalog_dir (
970- from_index = from_index_resolved , base_dir = os .path .join (temp_dir , 'from_index' )
971- )
969+ with set_registry_token (overwrite_from_index_token , from_index_resolved , append = True ):
970+ catalog_from_index = get_catalog_dir (
971+ from_index = from_index_resolved , base_dir = os .path .join (temp_dir , 'from_index' )
972+ )
972973 # overwrite data in `catalog_from_index` by data from `catalog_from_db`
973974 # this adds changes on not opted in operators to final
974975 merge_catalogs_dirs (catalog_from_db , catalog_from_index )
@@ -1094,9 +1095,10 @@ def handle_rm_request(
10941095
10951096 os .makedirs (os .path .join (temp_dir , 'from_index' ), exist_ok = True )
10961097 # get catalog with opted-in operators
1097- catalog_from_index = get_catalog_dir (
1098- from_index = from_index_resolved , base_dir = os .path .join (temp_dir , 'from_index' )
1099- )
1098+ with set_registry_token (overwrite_from_index_token , from_index_resolved , append = True ):
1099+ catalog_from_index = get_catalog_dir (
1100+ from_index = from_index_resolved , base_dir = os .path .join (temp_dir , 'from_index' )
1101+ )
11001102 # remove operators from from_index file-based catalog
11011103 for operator in operators :
11021104 operator_path = os .path .join (catalog_from_index , operator )
0 commit comments