What a job is doing right now.

A job that runs for ten minutes should not be a black box. Progress and logs make it observable, and dependency links show how it relates to the rest of a graph.

Progress, logs, dependencies

// Progress and logs (also available on the job object inside a processor)
await queue.updateJobProgress('job-id', 75);
await queue.addJobLog('job-id', 'Processing step 3 completed');
const { logs, count } = await queue.getJobLogs('job-id', 0, 100);

// Parent/child flows (see the Flow guide)
const childValues = await queue.getChildrenValues('parent-job-id');
const deps = await queue.getJobDependencies('job-id');
const processed = await queue.getDependencies('parent-id', 'processed', 0, 10);

// Wait for a job to finish (requires a QueueEvents instance)
import { QueueEvents } from 'bunqueue/client';
const queueEvents = new QueueEvents('my-queue', {
  embedded: false,
  connection: { host: '127.0.0.1', port: 6789 },
});
await queueEvents.waitUntilReady();
const result = await queue.waitJobUntilFinished('job-id', queueEvents, 30000);

// Progress and logs (also available on the job object inside a processor)
await queue.updateJobProgress('job-id', 75);
await queue.addJobLog('job-id', 'Processing step 3 completed');
const logs = await queue.getJobLogs('job-id', 0, 100);

// Parent/child flows (see the Flow guide)
const childValues = await queue.getChildrenValues('parent-job-id');

// Wait for a job to finish (throws on timeout or failure)
const result = await queue.waitForJob('job-id', 30000);

# Progress and logs (also available on the job object inside a processor)
queue.update_job_progress("job-id", 75)
queue.add_job_log("job-id", "Processing step 3 completed")
logs = queue.get_job_logs("job-id", 0, 100)

# Parent/child flows (see the Flow guide)
child_values = queue.get_children_values("parent-job-id")

# Wait for a job to finish (raises on timeout or failure)
result = queue.wait_for_job("job-id", timeout_ms=30000)

// Progress and logs (progress requires an active job)
$queue->getJob('job-id')?->updateProgress(75);
$queue->addJobLog('job-id', 'Processing step 3 completed');
$logs = $queue->getJobLogs('job-id');

// Parent/child flows (see the Flow guide)
$childValues = $queue->getChildrenValues('parent-job-id');

// Wait for a job to finish (throws on timeout or failure)
$result = $queue->waitForJob('job-id', 30000);

// Progress and logs (job methods; progress requires an active job)
job, _ := queue.GetJob("job-id")
job.UpdateProgress(75, "")
job.Log("Processing step 3 completed", "")
logs, _ := queue.GetJobLogs("job-id")

// Parent/child flows (see the Flow guide)
childValues, _ := queue.GetChildrenValues("parent-job-id")

// Wait for a job to finish (errors on timeout or failure)
result, _ := queue.WaitForJob("job-id", 30000)

// Progress and logs (job methods; progress requires an active job)
if let Some(job) = queue.get_job("job-id")? {
    job.update_progress(75.0, None)?;
    job.log("Processing step 3 completed", None)?;
}
let logs = queue.get_job_logs("job-id")?;

// Wait for a job to finish (errors on timeout or failure)
let result = queue.wait_for_job("job-id", 30_000)?;

# Progress and logs (job functions; progress requires an active job)
{:ok, job} = Bunqueue.Queue.get_job(queue, "job-id")
{:ok, _} = Bunqueue.Job.update_progress(job, 75)
{:ok, _} = Bunqueue.Job.log(job, "Processing step 3 completed")
{:ok, logs} = Bunqueue.Queue.get_logs(queue, "job-id")

# Wait for a job to finish (errors on timeout or failure)
{:ok, result} = Bunqueue.Queue.wait_for_job(queue, "job-id", 30_000)

getJobDependencies, getDependencies, and QueueEvents are available in the Bun bunqueue package. Bun QueueEvents supports both embedded and TCP brokers; use the same connection and prefixKey as the Queue. External SDKs expose waitForJob for the common wait-for-result case and can use SSE/WebSocket for live queue events.

Manual state transitions are BullMQ-compatible. Whenever the active job has a lock, token is mandatory and must be that job’s current worker token in both embedded and TCP mode. Jobs processed without locks remain administratively movable without one:

await queue.moveJobToCompleted('job-id', { success: true }, token);
await queue.moveJobToFailed('job-id', new Error('reason'), token);
await queue.moveJobToWait('job-id', token);
await queue.moveJobToDelayed('job-id', Date.now() + 60000, token);
await queue.moveJobToWaitingChildren('job-id', token);

await queue.moveJobToCompleted('job-id', { success: true }, token);
await queue.moveJobToFailed('job-id', new Error('reason'), token);
await queue.moveJobToWait('job-id');
await queue.moveJobToDelayed('job-id', 60000); // delay in ms

queue.move_job_to_completed("job-id", {"success": True}, token)
queue.move_job_to_failed("job-id", RuntimeError("reason"), token)
queue.move_job_to_wait("job-id")
queue.move_job_to_delayed("job-id", 60000)  # delay in ms

$queue->moveJobToFailed('job-id', new \RuntimeException('reason'), $token);

queue.MoveJobToFailed("job-id", errors.New("reason"), token)

// Worker::run() completes or fails pulled jobs with the lease token for you.
// Queue-level recovery remains available for an already failed job:
queue.retry_job("job-id")?;

:ok = Bunqueue.Queue.move_to_delayed(queue, "job-id", 60_000)  # delay in ms
:ok = Bunqueue.Queue.retry_job(queue, "job-id")                # failed -> waiting

The full token-bound transition set is available in TypeScript and Python; PHP and Go expose moveJobToFailed, Elixir exposes move_to_delayed and retry_job, and Rust intentionally leaves completion/failure acknowledgements to Worker while exposing queue-level retry.

Where to go next


Queue API	Create a queue in embedded or TCP mode
Adding Jobs	add, addBulk, priorities, delays, durability
Deduplication and Idempotent Job Adds	Idempotent adds, dedup keys, custom job ids
Querying Jobs	Fetch jobs, states, counts and results
Queue Control and Maintenance	Pause, drain, obliterate, clean and repair
Queue Rate Limiting and Global Concurrency	Rate limits and global concurrency caps
Job Schedulers from the Queue	Named repeatable schedules from the queue
DLQ Operations from the Queue Object	Failed-job operations from the Queue object
Workers, Stats and Metrics from the Queue	Registered workers, stats and metrics windows
Namespaces, Auto-Batching and Store-and-Forward	Namespaces, auto-batching, store-and-forward
JobOptions Reference	Every JobOptions field, with defaults