diff --git a/src/DIRAC/WorkloadManagementSystem/DB/JobDBUtils.py b/src/DIRAC/WorkloadManagementSystem/DB/JobDBUtils.py index 831456f1df8..5214d83d761 100644 --- a/src/DIRAC/WorkloadManagementSystem/DB/JobDBUtils.py +++ b/src/DIRAC/WorkloadManagementSystem/DB/JobDBUtils.py @@ -84,6 +84,7 @@ def checkAndPrepareJob(jobID, classAdJob, classAdReq, owner, ownerGroup, jobAttr if vo: classAdJob.insertAttributeString("VirtualOrganization", vo) + classAdReq.insertAttributeString("Owner", owner) classAdReq.insertAttributeString("OwnerGroup", ownerGroup) if vo: classAdReq.insertAttributeString("VirtualOrganization", vo) diff --git a/tests/Integration/WorkloadManagementSystem/Test_JobDB.py b/tests/Integration/WorkloadManagementSystem/Test_JobDB.py index bfa539de2c4..c1330432e54 100644 --- a/tests/Integration/WorkloadManagementSystem/Test_JobDB.py +++ b/tests/Integration/WorkloadManagementSystem/Test_JobDB.py @@ -168,6 +168,7 @@ def test_getJobJDL_nonOriginal(jobDB: JobDB): JobRequirements = [ CPUTime = 86400; + Owner = "owner"; OwnerGroup = "ownerGroup"; UserPriority = 1; VirtualOrganization = "vo";