Transfers: fix fts argument for scitag

rcarpa · Oct 18, 2023 · d6e70be · d6e70be
1 parent 6a5ccae
commit d6e70be
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/lib/rucio/transfertool/fts3.py b/lib/rucio/transfertool/fts3.py
@@ -942,7 +942,7 @@ def _file_from_transfer(self, transfer, job_params):
         if isinstance(self.scitags_exp_id, int):
             activity_id = self.scitags_activity_ids.get(rws.activity)
             if isinstance(activity_id, int):
-                t_file['metadata']['scitags_id'] = self.scitags_exp_id << 6 | activity_id
+                t_file['scitag'] = self.scitags_exp_id << 6 | activity_id
         return t_file
 
     def submit(self, transfers, job_params, timeout=None):

diff --git a/tests/test_conveyor.py b/tests/test_conveyor.py
@@ -577,7 +577,7 @@ def test_multihop_receiver_on_success(vo, did_factory, root_account, caches_mock
         fts_response = FTS3Transfertool(external_host=TEST_FTS_HOST).bulk_query({request['external_id']: {request['id']: request}})
         fts_response = fts_response[request['external_id']][request['id']]
         assert fts_response.job_response['priority'] == rule_priority
-        assert fts_response.file_response['file_metadata'].get('scitags_id') is not None
+        assert fts_response.file_response.get('scitag') is not None
 
         # Two hops; both handled by receiver
         assert metrics_mock.get_sample_value('rucio_daemons_conveyor_receiver_update_request_state_total', labels={'updated': 'True'}) >= 2