Jobs

from flexorch_sdk import FlexOrch

client = FlexOrch()

job = client.jobs.get("job_abc123")
print(job.status)         # "completed"
print(job.quality_grade)  # "A"
print(job.quality_score)  # 91

job = client.jobs.upload("document.pdf")
done = job.wait_until_done()

print(done.quality_grade)  # "A"

done = job.wait_until_done(
    timeout=120,      # seconds before JobTimeoutError is raised (default: 300)
    poll_interval=2,  # seconds between polls (default: 2)
)

from flexorch_sdk import JobFailedError, JobTimeoutError

try:
    done = job.wait_until_done(timeout=60)
except JobFailedError as e:
    print("Failed:", e.reason)    # e.job_id also available
except JobTimeoutError as e:
    print("Timed out:", e.job_id)

jobs = client.jobs.list(page=1, page_size=20)

for job in jobs.items:
    print(job.id, job.status, job.quality_grade)

dataset = job.dataset()

if dataset:
    print(dataset.id)
    print(dataset.row_count)
    client.datasets.export(dataset.id, format="jsonl", path="output.jsonl")

job.feedback(rating="negative", issue="wrong_fields")