Render Job Flow Map
Last reviewed: 2026-07-05
| Step | Status | Implementation | Notes |
|---|---|---|---|
| Load config | Implemented | load_settings() |
Defaults from ANUVA_CONFIG_PATH or C:\Anuva\Worker\config\worker.yaml. |
| Create workspace | Implemented | create_worker_workspace() |
Creates jobs, logs, cache/assets, temp, certs, simulator directories. |
| Auto poll | Implemented/Partial | JobRunner.poll_once() |
One pass only; continuous loop is not implemented. |
| Manual list | Implemented | JobRunner.list_available_jobs() |
Dashboard and CLI use summaries. |
| Manual claim guard | Implemented | _validate_manual_claim_allowed() |
Requires manual or hybrid; blocks busy worker by default. |
| Claim job | Implemented | webapp_client.claim_job() / manual_claim_job() |
Atomic semantics are delegated to Web App/simulator. |
| Package fetch | Implemented | webapp_client.get_job_package() |
Package model validates safe asset filenames and unique ids. |
| Job directories | Implemented | JobWorkspace.from_worker(...).create() |
Per-job assets/output/logs/diagnostics layout. |
| Health start snapshot | Implemented | _persist_health_snapshot("start") |
Writes diagnostics JSON. |
| Asset download | Implemented | download_assets() |
Retries, checksum validation, optional asset handling. |
| Config rewrite | Implemented | write_presentation_configs() |
Rewrites dicts with matching assetId and sibling url. |
| Manifest write | Implemented | write_job_manifest() |
Includes original URLs and local paths/URLs. |
| Mark in progress | Implemented | update_job_status(..., "inProgress", 0.0, "job package downloaded") |
Happens before Unity render. |
| Local content check | Implemented | _wait_for_local_content_ready() |
Probes config and asset local URLs. |
| Start Unity render | Implemented | UnityZmqClient.send_render_start() |
Sends local config path and URL plus output path. |
| Progress updates | Implemented | _wait_for_unity_render_completion() |
Forwards render.progress. |
| Completion | Implemented | complete_render() |
Validates MP4, thumbnail, upload, complete_job(). |
| Upload failure | Implemented | _handle_upload_failure() |
Sends uploadFailed then failure report. |
| Render failure | Implemented | render.failed branch |
Sends failure report with unityPayload. |
| Cancellation | Implemented/Partial | check_current_job_cancelled(), cancel_current_job() |
Polls summary on receive timeout; sends Unity cancel if rendering. |
| Cleanup | Partial | _return_to_idle() |
Clears in-memory active state; retention/delete policy not implemented. |
Core doc: RenderJobLifecycle.