How to use the dirac.lib.base.c.result function in DIRAC

To help you get started, we’ve selected a few DIRAC examples, based on popular ways it is used in public projects.

Secure your code as it's written. Use Snyk Code to scan source code in minutes - no build needed - and fix issues immediately.

github DIRACGrid / -obsolete-DIRACWeb / dirac / controllers / jobs / JobMonitor.py View on Github external
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
################################################################################
github DIRACGrid / -obsolete-DIRACWeb / dirac / controllers / jobs / JobMonitor.py View on Github external
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
################################################################################
github DIRACGrid / -obsolete-DIRACWeb / dirac / controllers / jobs / JobMonitor.py View on Github external
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
################################################################################
github DIRACGrid / -obsolete-DIRACWeb / dirac / controllers / jobs / JobMonitor.py View on Github external
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
################################################################################
github DIRACGrid / -obsolete-DIRACWeb / dirac / controllers / jobs / JobMonitor.py View on Github external
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
################################################################################
github DIRACGrid / -obsolete-DIRACWeb / dirac / controllers / jobs / JobMonitor.py View on Github external
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
################################################################################
github DIRACGrid / -obsolete-DIRACWeb / dirac / controllers / jobs / JobMonitor.py View on Github external
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
################################################################################
github DIRACGrid / -obsolete-DIRACWeb / dirac / controllers / jobs / JobMonitor.py View on Github external
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
################################################################################