MediaJobRetryingPayload media.job.retrying@1

Generated at from openvibe-contracts v0.33.0 and openvibe-sdk v0.5.0.

Version
1.0.0
Owner
media
Visibility
first-party
Status
active
Compatibility
backward
Decision
ADR-004
Schema
https://openvibe.network/contracts/events/payloads/media.job.retrying.v1.json

media.job.retrying v1 (OpenVibe.Media server/jobs/queue.js fail with a retry; server/events.js recordJob). An attempt failed and the job is queued again (status queued) after a backoff (run_after); error_code says why when the handler gave a code. A running job nobody holds any more (the service restarted, or the worker stopped renewing its lease) is retried this way with error_code interrupted while it has attempts left. Emitted in the SQLite transaction that records the state change, so the event exists if and only if the change committed; it goes to OpenVibe.Events only (no app webhook). The payload is an event projection of the job (queue.jobEvent): its identity, state, counters, stable error_code, times and has_result. Deliberately left out, because events travel beyond the tenant: the tenant's params (object.split keeps whatever the caller sent), the caller's idempotency_key, the free-text error (raw handler or ffmpeg output), the result (thumbnail.regenerate's is the thumbnail URL, of a private VOD too), created_by/decided_by and owner_user_id (tenant-local user ids), and the handler's checkpoint, lease and request hash. GET the job with a tenant token for params/result/error (GET /api/v2/:app/jobs/:id with a token for app_id; has_result says whether there is a result to fetch). Times are ISO 8601 UTC (YYYY-MM-DDTHH:MM:SS.sssZ) or null. Jobs of developer-project sandbox tenants are not announced. Envelope: subject { type: job, id: <id> }, visibility internal, priority low, actor service:media.

Fields

FieldTypeRequiredDescriptionConstraints
idstringyesThe job. GET /api/v2/:app/jobs/:id with a token for app_id answers the rest of it.
  • pattern ^mjob_[0-9A-HJKMNP-TV-Z]{26}$
app_idstringyesThe tenant that owns the job: an app (live, tools…) or a developer project's production tenant (prj_…).
  • minLength 1
  • maxLength 200
object_idstring | nullyesThe object the job works on; null for a tenant-wide job (invariant.scan).
  • maxLength 200
typestringyesJob type: thumbnail.regenerate, invariant.scan, object.split or object.remux.
  • pattern ^[a-z][a-z0-9]*\.[a-z0-9_.]+$
  • maxLength 80
statusconstyesretrying carries the job's state, queued.
  • = "queued"
attemptsintegeryesAttempts started so far, the failed one included.
  • minimum 1
max_attemptsintegeryes
  • minimum 1
  • maximum 10
error_codestring | nullyesStable code of the last failure (media_unavailable, interrupted, cancelled, media.job.invalid…), or null when there was none or the handler gave no code. Never the message: GET the job for it.
cancel_requestedbooleanyesIts owner asked a running job to stop.
has_resultconstyesA job waiting for its retry has no result.
  • = false
run_afterstringyesNot before this time (the retry backoff).
  • pattern ^[0-9]{4}-[0-9]{2}-[0-9]{2}T[0-9]{2}:[0-9]{2}:[0-9]{2}(\.[0-9]{1,3})?Z$
  • format date-time
decided_atstring | nullyesWhen its owner approved it, or cancelled it while it was proposed or queued; null otherwise.
  • pattern ^[0-9]{4}-[0-9]{2}-[0-9]{2}T[0-9]{2}:[0-9]{2}:[0-9]{2}(\.[0-9]{1,3})?Z$
  • format date-time
created_atstringyes
  • pattern ^[0-9]{4}-[0-9]{2}-[0-9]{2}T[0-9]{2}:[0-9]{2}:[0-9]{2}(\.[0-9]{1,3})?Z$
  • format date-time
updated_atstringyes
  • pattern ^[0-9]{4}-[0-9]{2}-[0-9]{2}T[0-9]{2}:[0-9]{2}:[0-9]{2}(\.[0-9]{1,3})?Z$
  • format date-time
started_atstringyesThe first attempt's start.
  • pattern ^[0-9]{4}-[0-9]{2}-[0-9]{2}T[0-9]{2}:[0-9]{2}:[0-9]{2}(\.[0-9]{1,3})?Z$
  • format date-time
finished_atnullyes

Examples

From the contract's own test fixtures: valid ones validate, rejected ones must fail.

Valid: interrupted
{
  "id": "mjob_01JAB3C4D5E6F7G8H9J0K1MNPQ",
  "app_id": "live",
  "object_id": "med_01JAB2C3D4E5F6G7H8J9K0MNPQ",
  "type": "object.split",
  "status": "queued",
  "attempts": 1,
  "max_attempts": 3,
  "error_code": "interrupted",
  "cancel_requested": false,
  "has_result": false,
  "run_after": "2026-09-23T18:05:42.000Z",
  "decided_at": null,
  "created_at": "2026-09-23T18:02:11.000Z",
  "updated_at": "2026-09-23T18:05:12.000Z",
  "started_at": "2026-09-23T18:02:12.000Z",
  "finished_at": null
}
Valid: no-code
{
  "id": "mjob_01JAB3C4D5E6F7G8H9J0K1MNPQ",
  "app_id": "live",
  "object_id": "med_01JAB2C3D4E5F6G7H8J9K0MNPQ",
  "type": "object.split",
  "status": "queued",
  "attempts": 1,
  "max_attempts": 3,
  "error_code": null,
  "cancel_requested": false,
  "has_result": false,
  "run_after": "2026-09-23T18:02:43.000Z",
  "decided_at": null,
  "created_at": "2026-09-23T18:02:11.000Z",
  "updated_at": "2026-09-23T18:02:13.000Z",
  "started_at": "2026-09-23T18:02:12.000Z",
  "finished_at": null
}
Rejected: carries-error-text
{
  "id": "mjob_01JAB3C4D5E6F7G8H9J0K1MNPQ",
  "app_id": "live",
  "object_id": "med_01JAB2C3D4E5F6G7H8J9K0MNPQ",
  "type": "object.split",
  "status": "queued",
  "attempts": 1,
  "max_attempts": 3,
  "error_code": "interrupted",
  "cancel_requested": false,
  "has_result": false,
  "run_after": "2026-09-23T18:05:42.000Z",
  "decided_at": null,
  "created_at": "2026-09-23T18:02:11.000Z",
  "updated_at": "2026-09-23T18:05:12.000Z",
  "started_at": "2026-09-23T18:02:12.000Z",
  "finished_at": null,
  "error": "interrupted by a restart"
}
Rejected: no-backoff
{
  "id": "mjob_01JAB3C4D5E6F7G8H9J0K1MNPQ",
  "app_id": "live",
  "object_id": "med_01JAB2C3D4E5F6G7H8J9K0MNPQ",
  "type": "object.split",
  "status": "queued",
  "attempts": 1,
  "max_attempts": 3,
  "error_code": "interrupted",
  "cancel_requested": false,
  "has_result": false,
  "run_after": null,
  "decided_at": null,
  "created_at": "2026-09-23T18:02:11.000Z",
  "updated_at": "2026-09-23T18:05:12.000Z",
  "started_at": "2026-09-23T18:02:12.000Z",
  "finished_at": null
}
Rejected: status-retrying
{
  "id": "mjob_01JAB3C4D5E6F7G8H9J0K1MNPQ",
  "app_id": "live",
  "object_id": "med_01JAB2C3D4E5F6G7H8J9K0MNPQ",
  "type": "object.split",
  "status": "retrying",
  "attempts": 1,
  "max_attempts": 3,
  "error_code": "interrupted",
  "cancel_requested": false,
  "has_result": false,
  "run_after": "2026-09-23T18:05:42.000Z",
  "decided_at": null,
  "created_at": "2026-09-23T18:02:11.000Z",
  "updated_at": "2026-09-23T18:05:12.000Z",
  "started_at": "2026-09-23T18:02:12.000Z",
  "finished_at": null
}

Validate

const contracts = require('openvibe-contracts');
contracts.validate('media.job.retrying@1', value);   // { valid, errors: [{ path, message }] }