@@ -687,7 +687,7 @@ def cancelTimer(self):
687
687
self ._timer .cancel ()
688
688
689
689
690
- def sendMessage (url , pilotUUID , wnVO , method , rawMessage , withJWT = False , jwt = {}):
690
+ def sendMessage (url , pilotUUID , wnVO , method , rawMessage , jwt = {}):
691
691
"""
692
692
Invoke a remote method on a Tornado server and pass a JSON message to it.
693
693
@@ -696,7 +696,6 @@ def sendMessage(url, pilotUUID, wnVO, method, rawMessage, withJWT=False, jwt={})
696
696
:param str wnVO: VO name, relevant only if not contained in a proxy
697
697
:param str method: a method to be invoked
698
698
:param str rawMessage: a message to be sent, in JSON format
699
- :param bool withJWT: tells if we use or not JWT
700
699
:param dict jwt: JWT for the requests
701
700
:return: None.
702
701
"""
@@ -708,7 +707,7 @@ def sendMessage(url, pilotUUID, wnVO, method, rawMessage, withJWT=False, jwt={})
708
707
709
708
config = None
710
709
711
- if withJWT :
710
+ if jwt :
712
711
try :
713
712
access_token = jwt ["access_token" ]
714
713
except ValueError as e :
@@ -1034,7 +1033,7 @@ def __init__(self):
1034
1033
("y:" , "CEType=" , "CE Type (normally InProcess)" ),
1035
1034
("z" , "pilotLogging" , "Activate pilot logging system" ),
1036
1035
("C:" , "configurationServer=" , "Configuration servers to use" ),
1037
- ("" , "diracXServer =" , "DiracX server to use" ),
1036
+ ("" , "diracx_URL =" , "DiracX Server URL to use" ),
1038
1037
("D:" , "disk=" , "Require at least <space> MB available" ),
1039
1038
("E:" , "commandExtensions=" , "Python modules with extra commands" ),
1040
1039
("F:" , "pilotCFGFile=" , "Specify pilot CFG file" ),
0 commit comments