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 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",