process_celery_tasks.py¶

Generated: 2026-03-30T04:38:47.806471+00:00

Commit: 615f1354a103

Language: python

Scope: dazzle_back

Purpose¶

Celery tasks for process execution.

These tasks handle: - Individual step execution within a process - Saga compensation on failure - Human task timeout checking - Scheduled process triggering

Configuration: Set REDIS_URL environment variable for Redis connection. Run worker with: celery -...

Key Exports¶

execute_process
check_human_task_timeout
resume_process_after_task
trigger_scheduled_process

Dependencies¶

Imports¶

logging
os
ssl
datetime.UTC
datetime.datetime
typing.Any
celery.Celery
dazzle.core.ir.process.StepKind
dazzle.core.process.adapter.ProcessRun
dazzle.core.process.adapter.ProcessStatus
dazzle.core.process.adapter.ProcessTask
dazzle.core.process.adapter.TaskStatus
dazzle.core.process.celery_state.ProcessStateStore
celery.exceptions.MaxRetriesExceededError
psycopg
uuid
uuid
datetime.timedelta
datetime.UTC
datetime.date

Event Interactions¶

None detected.

Invariants and Assumptions¶

No invariants documented.

Tests¶

tests/integration/test_runtime_e2e.py
tests/integration/test_runtime_pipeline.py
tests/unit/test_runtime_test_routes.py
tests/unit/test_runtime_services.py
tests/unit/test_runtime_mcp_tools.py

Notes¶

This page was automatically generated by tools/gen_reference_docs.py.