From a75d942211e465c00454f2a9a5abbbee72c4edfc Mon Sep 17 00:00:00 2001 From: Fernando Barreiro Date: Tue, 18 Nov 2025 15:52:32 +0100 Subject: [PATCH 1/2] get_jobs_attributes_for_panda: removed computing_element --- pandaharvester/harvestercore/job_spec.py | 1 - 1 file changed, 1 deletion(-) diff --git a/pandaharvester/harvestercore/job_spec.py b/pandaharvester/harvestercore/job_spec.py index b452afd8..b7d8dd56 100644 --- a/pandaharvester/harvestercore/job_spec.py +++ b/pandaharvester/harvestercore/job_spec.py @@ -431,7 +431,6 @@ def get_job_attributes_for_panda(self): "exeErrorCode": "exe_error_code", "exeErrorDiag": "exe_error_diag", "pilotTiming": "pilot_timing", - "computingElement": "computing_element", "startTime": "start_time", "endTime": "end_time", "nEvents": "n_events", From 0562e41308b2b57462998569d8e4c24cf776bd6f Mon Sep 17 00:00:00 2001 From: Fernando Barreiro Date: Tue, 18 Nov 2025 18:32:35 +0100 Subject: [PATCH 2/2] Added harvester_id to update_jobs_bulk call --- pandaharvester/harvestercommunicator/panda_communicator.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/pandaharvester/harvestercommunicator/panda_communicator.py b/pandaharvester/harvestercommunicator/panda_communicator.py index f1bae081..70f8bdc2 100644 --- a/pandaharvester/harvestercommunicator/panda_communicator.py +++ b/pandaharvester/harvestercommunicator/panda_communicator.py @@ -392,7 +392,7 @@ def update_jobs(self, jobspec_list, id): job_list.append(job_dict) # data dictionary to be sent to PanDA server - data = {"job_list": job_list} + data = {"job_list": job_list, "harvester_id": harvester_config.master.harvester_id} tmp_status, tmp_response = self.request_ssl("POST", "pilot/update_jobs_bulk", data) ret_maps = None