File tree Expand file tree Collapse file tree 1 file changed +3
-2
lines changed
src/DIRAC/WorkloadManagementSystem/Service Expand file tree Collapse file tree 1 file changed +3
-2
lines changed Original file line number Diff line number Diff line change 6
6
7
7
from DIRAC import S_OK , S_ERROR , gLogger , gConfig
8
8
from DIRAC .ConfigurationSystem .Client .Helpers .Resources import getQueue
9
- from DIRAC .ConfigurationSystem .Client .Helpers .Registry import getGroupOption , getUsernameForDN
9
+ from DIRAC .ConfigurationSystem .Client .Helpers .Registry import getGroupOption , getUsernameForDN , getVOForGroup
10
10
from DIRAC .FrameworkSystem .Client .ProxyManagerClient import gProxyManager
11
11
from DIRAC .FrameworkSystem .Client .TokenManagerClient import gTokenManager
12
12
from DIRAC .Resources .Computing .ComputingElementFactory import ComputingElementFactory
@@ -75,7 +75,8 @@ def setPilotCredentials(ce, pilotDict):
75
75
:param pilotDict: pilot parameter dictionary
76
76
:return: S_OK/S_ERROR
77
77
"""
78
- if "Token" in ce .ceParameters .get ("Tag" , []):
78
+ vo = getVOForGroup (pilotDict ["OwnerGroup" ])
79
+ if "Token" in ce .ceParameters .get ("Tag" , []) or f"Token:{ vo } " in ce .ceParameters .get ("Tag" , []):
79
80
result = gTokenManager .getToken (
80
81
userGroup = pilotDict ["OwnerGroup" ],
81
82
scope = PILOT_SCOPES ,
You can’t perform that action at this time.
0 commit comments