@@ -687,7 +687,7 @@ def cancelTimer(self):
687687 self ._timer .cancel ()
688688
689689
690- def sendMessage (url , pilotUUID , wnVO , method , rawMessage , withJWT = False , jwt = {}):
690+ def sendMessage (url , pilotUUID , wnVO , method , rawMessage , jwt = {}):
691691 """
692692 Invoke a remote method on a Tornado server and pass a JSON message to it.
693693
@@ -696,7 +696,6 @@ def sendMessage(url, pilotUUID, wnVO, method, rawMessage, withJWT=False, jwt={})
696696 :param str wnVO: VO name, relevant only if not contained in a proxy
697697 :param str method: a method to be invoked
698698 :param str rawMessage: a message to be sent, in JSON format
699- :param bool withJWT: tells if we use or not JWT
700699 :param dict jwt: JWT for the requests
701700 :return: None.
702701 """
@@ -708,7 +707,7 @@ def sendMessage(url, pilotUUID, wnVO, method, rawMessage, withJWT=False, jwt={})
708707
709708 config = None
710709
711- if withJWT :
710+ if jwt :
712711 try :
713712 access_token = jwt ["access_token" ]
714713 except ValueError as e :
@@ -1034,7 +1033,7 @@ def __init__(self):
10341033 ("y:" , "CEType=" , "CE Type (normally InProcess)" ),
10351034 ("z" , "pilotLogging" , "Activate pilot logging system" ),
10361035 ("C:" , "configurationServer=" , "Configuration servers to use" ),
1037- ("" , "diracXServer =" , "DiracX server to use" ),
1036+ ("" , "diracx_URL =" , "DiracX server to use" ),
10381037 ("D:" , "disk=" , "Require at least <space> MB available" ),
10391038 ("E:" , "commandExtensions=" , "Python modules with extra commands" ),
10401039 ("F:" , "pilotCFGFile=" , "Specify pilot CFG file" ),
0 commit comments