import arc
import sys
import os
def example():
uc = arc.UserConfig()
uc.ProxyPath("/tmp/x509up_u%s" % os.getuid())
uc.CACertificatesDirectory("/etc/grid-security/certificates")
endpoint = arc.Endpoint("piff.hep.lu.se:443/arex", arc.Endpoint.COMPUTINGINFO)
jobs = arc.JobContainer()
retriever = arc.JobListRetriever(uc)
retriever.addConsumer(jobs)
retriever.addEndpoint(endpoint)
retriever.wait()
sys.stdout.write("%s\n"%retriever.getStatusOfEndpoint(endpoint).str())
sys.stdout.write("Number of jobs found: %d\n"%len(jobs))
for job in jobs:
job.SaveToStream(arc.CPyOstream(sys.stdout), True)
import atexit
@atexit.register
def wait_exit():
arc.ThreadInitializer().waitExit()
example()