JobResult¶

::: taskito.result.JobResult

Handle to an enqueued job. Provides methods to check status and retrieve results, both synchronously and asynchronously.

Returned by task.delay(), task.apply_async(), queue.enqueue(), and canvas operations.

Properties¶

job.id¶

job.id -> str

The unique job ID (UUIDv7, time-ordered).

job.status¶

job.status -> str

Current job status. Fetches fresh from the database on every access.

Returns one of: "pending", "running", "complete", "failed", "dead", "cancelled".

job = add.delay(2, 3)
print(job.status)  # "pending"
# ... after worker processes it ...
print(job.status)  # "complete"

job.progress¶

job.progress -> int | None

Current progress (0–100) if reported by the task via current_job.update_progress(). Returns None if no progress has been reported. Refreshes from the database.

job.error¶

job.error -> str | None

Error message if the job failed. None if the job hasn't failed. Refreshes from the database.

job.errors¶

job.errors -> list[dict]

Full error history for this job — one entry per failed attempt. Each dict contains:

job = flaky_task.delay()
# ... after retries ...
for err in job.errors:
    print(f"Attempt {err['attempt']}: {err['error']}")

job.dependencies¶

job.dependencies -> list[str]

List of job IDs this job depends on. Returns an empty list if the job has no dependencies. See Dependencies.

job.dependents¶

job.dependents -> list[str]

List of job IDs that depend on this job. Returns an empty list if no other jobs depend on this one.

Methods¶

job.to_dict()¶

job.to_dict() -> dict

Return all job fields as a plain dictionary. Useful for JSON serialization (e.g. in the dashboard or FastAPI integration).

job.result()¶

job.result(
    timeout: float = 30.0,
    poll_interval: float = 0.05,
    max_poll_interval: float = 0.5,
) -> Any

Block until the job completes and return the deserialized result. Uses exponential backoff for polling — starts at poll_interval and gradually increases to max_poll_interval.

Raises:

• TimeoutError — if the job doesn't complete within timeout
• RuntimeError — if the job status is "failed" or "dead"

job = add.delay(2, 3)
result = job.result(timeout=10)  # blocks, returns 5

# Custom polling for long-running tasks
result = job.result(timeout=600, poll_interval=1.0, max_poll_interval=5.0)

await job.aresult()¶

async job.aresult(
    timeout: float = 30.0,
    poll_interval: float = 0.05,
    max_poll_interval: float = 0.5,
) -> Any

Async version of result(). Uses asyncio.sleep() instead of time.sleep(), so it won't block the event loop.

Raises:

• TimeoutError — if the job doesn't complete within timeout
• RuntimeError — if the job status is "failed" or "dead"

job = add.delay(2, 3)
result = await job.aresult(timeout=10)