feat(silo): handle DAG and job SSE events (#218) #227
Reference in New Issue
Block a user
Delete Branch "feat/silo-sse-dag-events"
Deleting a branch is permanent. Although the deleted branch may continue to exist for a short time before it actually gets removed, it CANNOT be undone in most cases. Continue?
Extends
SiloEventListenerwith signals for DAG and job lifecycle SSE events.New Signals
DAG events:
dag_updated(part_number, node_count, edge_count)— emitted after any DAG syncdag_validated(part_number, valid, failed_count)— emitted after validation completesJob lifecycle events:
job_created(job_id, definition_name, part_number)job_claimed(job_id, runner_id)job_progress(job_id, progress, message)job_completed(job_id)job_failed(job_id, error)job_cancelled(job_id)Dispatch logic in
_dispatch()parses JSON payloads and emits typed Qt signals for downstream consumers (Activity panel, logging, etc.).Closes #218