@@ -25,8 +25,9 @@ def main():
25
25
if switch [0 ] == "v" or switch [0 ] == "vo" :
26
26
vo = switch [1 ]
27
27
28
- from DIRAC import S_OK , S_ERROR
29
- from DIRAC import gConfig , gLogger
28
+ from DIRAC import S_OK
29
+ from DIRAC import gLogger
30
+ from DIRAC .ConfigurationSystem .Client .Helpers .Operations import Operations
30
31
from DIRAC .ConfigurationSystem .Client .CSAPI import CSAPI
31
32
32
33
def updatePilot (version , vo ):
@@ -38,21 +39,24 @@ def updatePilot(version, vo):
38
39
:param version: version vArBpC of pilot you want to use
39
40
:param vo: Location of pilot version in CS /Operations/<vo>/Pilot/Version
40
41
"""
41
- # FIXME: use Operations() object
42
- pilotVersion = gConfig . getValue ( f"Operations/ { vo } /Pilot/Version" , [])
43
- if not pilotVersion :
44
- return S_ERROR ( f"No pilot version set under Operations/ { vo } /Pilot/Version in CS" )
45
-
46
- pilotVersion .pop ()
47
- pilotVersion .insert (0 , version )
42
+ res = Operations (vo = vo ). getValue ( "Pilot/Version" , [])
43
+ if not res [ "OK" ]:
44
+ gLogger . warn ( "No pilot version set in CS" )
45
+ pilotVersion = [ version ]
46
+ else :
47
+ pilotVersion = [ res [ "Value" ] .pop ()]
48
+ pilotVersion .insert (0 , version )
48
49
api = CSAPI ()
49
- api .setOption (f"Operations/{ vo } /Pilot/Version" , ", " .join (pilotVersion ))
50
+ if vo :
51
+ api .setOption (f"Operations/{ vo } /Pilot/Version" , ", " .join (pilotVersion ))
52
+ else :
53
+ api .setOption ("Operations/Defaults/Pilot/Version" , ", " .join (pilotVersion ))
50
54
result = api .commit ()
51
55
if not result ["OK" ]:
52
56
gLogger .fatal ("Could not commit new version of pilot!" )
53
57
return result
54
58
55
- newVersion = gConfig .getValue (f"Operations/ { vo } / Pilot/Version" )
59
+ newVersion = Operations ( vo = vo ) .getValue (" Pilot/Version" )
56
60
return S_OK (f"New version of pilot set to { newVersion } " )
57
61
58
62
result = updatePilot (version , vo )
0 commit comments