diff --git a/src/DIRAC/WorkloadManagementSystem/JobWrapper/JobWrapper.py b/src/DIRAC/WorkloadManagementSystem/JobWrapper/JobWrapper.py
index 37ab3390ecf..4ea8287951a 100755
--- a/src/DIRAC/WorkloadManagementSystem/JobWrapper/JobWrapper.py
+++ b/src/DIRAC/WorkloadManagementSystem/JobWrapper/JobWrapper.py
@@ -244,6 +244,7 @@ def __setInitialJobParameters(self):
         parameters = []
         parameters.append(("Pilot_Reference", self.ceArgs.get("PilotReference", self.pilotRef)))
         parameters.append(("JobType", self.jobArgs.get("JobType", self.jobType)))
+        parameters.append(("JobGroup", self.jobArgs.get("JobGroup", self.jobGroup)))
         if "LocalSE" in self.ceArgs:
             parameters.append(("AgentLocalSE", ",".join(self.ceArgs["LocalSE"])))
         if "CPUNormalizationFactor" in self.ceArgs: