Jobs API

[kellrott]

TODOs

• Add testing for as / select in job resume
• Add page to documentation
• Add timestamps for jobs

The Jobs API:

To submit a job:

job = G.query().V().hasLabel("Planet").out().submit()

To get job status:

jinfo = G.getJob(job["id"])

To read job results:

for row in G.readJob(job["id"]):
   print(row)

Find jobs that match the prefix of the current request (example should find job from G.query().V().hasLabel("Planet").out())

jobs = G.query().V().hasLabel("Planet").out().out().count().searchJobs()

Extend a previous pipeline

for res in G.resume(job["id"]).out().count():
    print(res)