Secure your code as it's written. Use Snyk Code to scan source code in minutes - no build needed - and fix issues immediately.
if secondsOverride and str(secondsOverride).isdigit():
validSeconds = int(secondsOverride)
else:
defaultSeconds = 24 * 3600 + 60 # 24H + 1min
validSeconds = gConfig.getValue("/Registry/DefaultProxyLifeTime",defaultSeconds)
gLogger.info("\033[0;31m userHasProxy(%s, %s, %s) \033[0m" % (userDN,group,validSeconds))
result = proxyManager.userHasProxy(userDN,group,validSeconds)
if result["OK"]:
if result["Value"]:
c.result = {"success":"true","result":"true"}
else:
c.result = {"success":"true","result":"false"}
else:
c.result = {"success":"false","error":"false"}
gLogger.info("\033[0;31m PROXY: \033[0m",result)
return c.result
################################################################################
for key in keylist:
if selector == "Site" and tier1:
if key not in tier1:
try:
countryCode = key.rsplit(".",1)[1]
except:
countryCode = "Unknown"
c.result.append({"Key":key,"Value":result[key],"Code":countryCode})
elif selector == "Site" and not tier1:
try:
countryCode = key.rsplit(".",1)[1]
except:
countryCode = "Unknown"
c.result.append({"Key":key,"Value":result[key],"Code":countryCode})
else:
c.result.append({"Key":key,"Value":result[key]})
c.result = {"success":"true","result":c.result}
else:
c.result = {"success":"false","error":result["Message"]}
return c.result
################################################################################
def __pilotGetURL(self,id):
print "LogFile:",id
RPC = getRPCClient("WorkloadManagement/JobMonitoring")
result = RPC.getJobParameters(id)
if result["OK"]:
attr = result["Value"]
if attr.has_key("Log URL"):
url = attr["Log URL"]
url = url.split('"')
c.result = url[1]
c.result = {"success":"true","result":c.result}
else:
c.result = "No URL found"
c.result = {"success":"false","error":c.result}
else:
c.result = {"success":"false","error":result["Message"]}
gLogger.info("pilotGetURL:",id)
return c.result
################################################################################
def __rescheduleJobs(self,id):
MANAGERRPC = getRPCClient("WorkloadManagement/JobManager")
result = MANAGERRPC.rescheduleJob(id)
if result["OK"]:
c.result = ""
c.result = {"success":"true","result":c.result}
else:
if result.has_key("InvalidJobIDs"):
c.result = "Invalid JobIDs: %s" % result["InvalidJobIDs"]
c.result = {"success":"false","error":c.result}
elif result.has_key("NonauthorizedJobIDs"):
c.result = "You are nonauthorized to delete jobs with JobID: %s" % result["NonauthorizedJobIDs"]
c.result = {"success":"false","error":c.result}
else:
c.result = {"success":"false","error":result["Message"]}
gLogger.info("RESET:",id)
return c.result
################################################################################
gLogger.info("-RES:",result)
if result["OK"]:
result = result["Value"]
if img == 'True':
result = result["plot"]
else:
result = result["thumbnail"]
c.result = {"success":"true","result":result}
self.__imgCache.add(name, 600, result)
else:
c.result = {"success":"false","error":result["Message"]}
else:
c.result = {"success":"false","error":result["Message"]}
else:
c.result = {"success":"true","result":result}
gLogger.info("getPlotSrc:",c.result)
return c.result
################################################################################
def __getStandardOutput(self,id):
RPC = getRPCClient("WorkloadManagement/JobMonitoring")
result = RPC.getJobParameters(id)
if result["OK"]:
attr = result["Value"]
if attr.has_key("StandardOutput"):
c.result = attr["StandardOutput"]
c.result = {"success":"true","result":c.result}
else:
c.result = "Not accessible yet"
c.result = {"success":"false","error":c.result}
else:
c.result = {"success":"false","error":result["Message"]}
gLogger.info("StandardOutput:",id)
return c.result
################################################################################
def __delJobs(self,id):
MANAGERRPC = getRPCClient("WorkloadManagement/JobManager")
result = MANAGERRPC.deleteJob(id)
if result["OK"]:
c.result = ""
c.result = {"success":"true","result":c.result}
else:
if result.has_key("InvalidJobIDs"):
c.result = "Invalid JobIDs: %s" % result["InvalidJobIDs"]
c.result = {"success":"false","error":c.result}
elif result.has_key("NonauthorizedJobIDs"):
c.result = "You are nonauthorized to delete jobs with JobID: %s" % result["NonauthorizedJobIDs"]
c.result = {"success":"false","error":c.result}
else:
c.result = {"success":"false","error":result["Message"]}
gLogger.info("DELETE:",id)
return c.result
################################################################################
def __rescheduleJobs(self,id):
MANAGERRPC = getRPCClient("WorkloadManagement/JobManager")
result = MANAGERRPC.rescheduleJob(id)
if result["OK"]:
c.result = ""
c.result = {"success":"true","result":c.result}
else:
if result.has_key("InvalidJobIDs"):
c.result = "Invalid JobIDs: %s" % result["InvalidJobIDs"]
c.result = {"success":"false","error":c.result}
elif result.has_key("NonauthorizedJobIDs"):
c.result = "You are nonauthorized to delete jobs with JobID: %s" % result["NonauthorizedJobIDs"]
c.result = {"success":"false","error":c.result}
else:
c.result = {"success":"false","error":result["Message"]}
gLogger.info("RESET:",id)
return c.result
################################################################################