10 uc.ProxyPath(
"/tmp/x509up_u%s" % os.getuid())
11 uc.CACertificatesDirectory(
"/etc/grid-security/certificates")
14 endpoint = arc.Endpoint(
"piff.hep.lu.se:443/arex", arc.Endpoint.COMPUTINGINFO)
15 print "Querying %s for jobs..." % endpoint.str()
16 jobs = arc.JobContainer()
17 retriever = arc.JobListRetriever(uc)
18 retriever.addConsumer(jobs)
19 retriever.addEndpoint(endpoint)
22 print "%s jobs found" % len(jobs)
25 job_supervisor = arc.JobSupervisor(uc, jobs)
27 print "Getting job states..."
29 job_supervisor.Update()
32 jobs = job_supervisor.GetAllJobs()
34 print "The jobs have the following states:",
", ".
join([job.State.GetGeneralState()
for job
in jobs])
37 job_supervisor.SelectByStatus([
"Failed"])
38 failed_jobs = job_supervisor.GetSelectedJobs()
40 print "The failed jobs:"
41 for job
in failed_jobs:
42 job.SaveToStream(arc.CPyOstream(sys.stdout),
True)
48 arc.ThreadInitializer().waitExit()