События сервиса нужны для projections, audit, troubleshooting и синхронизации с control-plane-service. Kafka используется как event transport, но не как источник истины: authoritative state хранится в PostgreSQL execution-plane-service.

Event Envelope

 1
 2
 3
 4
 5
 6
 7
 8
 9
10
11

event:
  id: uuid
  type: execution.attempt.started
  version: 1
  occurred_at: "2026-04-29T10:01:00Z"
  producer: execution-plane-service
  correlation_id: op-123
  causation_id: exec-attempt-123
  tenant_id: tenant-1
  project_id: project-1
  payload: {}

Правила:

• event.id уникален глобально.
• correlation_id обычно равен operation_id.
• causation_id равен attempt_id или команде, которая вызвала событие.
• Payload не содержит secret values.
• Публикация выполняется через outbox pattern из той же БД.

Published Events

execution.attempt.queued

Attempt создан и ожидает runner.

1
2
3
4
5
6
7
8

payload:
  attempt_id: exec-attempt-123
  operation_id: op-123
  plan_id: plan-123
  plan_node_id: install-runtime
  node_run_id: node-run-456
  job_type: ansible.playbook.run
  runner_kind: ansible

execution.attempt.leased

Runner получил lease.

1
2
3
4
5

payload:
  attempt_id: exec-attempt-123
  runner_instance_id: ansible-runner-7
  runner_kind: ansible
  lease_expires_at: "2026-04-29T10:10:00Z"

execution.attempt.started

Runner начал выполнение.

1
2
3
4

payload:
  attempt_id: exec-attempt-123
  runner_instance_id: ansible-runner-7
  started_at: "2026-04-29T10:01:00Z"

execution.attempt.progressed

Heartbeat/progress snapshot.

1
2
3
4
5

payload:
  attempt_id: exec-attempt-123
  phase: executing
  progress_percent: 42
  message: installing container runtime

Не каждый heartbeat обязан становиться Kafka event. Сервис может публиковать sampled progress events, а полную heartbeat history хранить в БД.

artifact.created

Создан artifact или log bundle.

1
2
3
4
5
6
7
8

payload:
  artifact_ref:
    id: artifact-123
    uri: s3://aiops-artifacts/executions/exec-attempt-123/logs.tar.zst
    digest: sha256:abc
    content_type: application/zstd
  attempt_id: exec-attempt-123
  artifact_kind: log_bundle

execution.attempt.succeeded

Техническое выполнение завершилось успешно.

 1
 2
 3
 4
 5
 6
 7
 8
 9
10

payload:
  attempt_id: exec-attempt-123
  operation_id: op-123
  plan_node_id: install-runtime
  node_run_id: node-run-456
  output_refs:
    - artifact://outputs/exec-attempt-123/recap.json
  evidence_refs:
    - evidence://exec-attempt-123/containerd-active
  finished_at: "2026-04-29T10:20:00Z"

Это не означает automatic business success всей операции.

execution.attempt.failed

Техническое выполнение завершилось ошибкой.

 1
 2
 3
 4
 5
 6
 7
 8
 9
10

payload:
  attempt_id: exec-attempt-123
  operation_id: op-123
  plan_node_id: install-runtime
  node_run_id: node-run-456
  failure_category: command_failed
  exit_code: 2
  log_refs:
    - artifact://logs/exec-attempt-123/bundle.tar.zst
  finished_at: "2026-04-29T10:20:00Z"

execution.attempt.cancelled

Attempt остановлен по запросу.

1
2
3
4
5

payload:
  attempt_id: exec-attempt-123
  cancellation_reason: user_cancelled_operation
  partial_artifact_refs:
    - artifact://logs/exec-attempt-123/partial.tar.zst

execution.attempt.timed_out

Attempt превысил timeout.

1
2
3
4

payload:
  attempt_id: exec-attempt-123
  timeout_seconds: 1800
  last_phase: executing

execution.attempt.heartbeat_lost

Runner перестал отправлять heartbeat.

1
2
3
4

payload:
  attempt_id: exec-attempt-123
  runner_instance_id: ansible-runner-7
  last_heartbeat_at: "2026-04-29T10:05:00Z"

Consumed Commands / Events

Основной command path идет через internal API, но сервис может потреблять control events:

• operation.cancel_requested - запросить cancellation для связанных attempts;
• runner.drain_requested - перестать выдавать новые leases конкретному runner pool;
• artifact.retention_policy.changed - пересчитать retention для bundles.

Эти events не заменяют API для запуска jobs.

Ordering

• Для одного attempt_id events публикуются в порядке attempt_events.created_at.
• Для разных attempts глобальный порядок не гарантируется.
• Consumers должны быть idempotent.

Delivery

• Outbox row создается в той же транзакции, что и state change.
• Event worker публикует row в Kafka.
• После publish фиксируется delivery status.
• Re-publish допускается, consumers дедуплицируют по event.id.

Consumers

Основные consumers:

• control-plane-service.event-worker - связывает attempt events с operation/node timeline;
• audit integration - future extension point;
• observability pipeline - metrics/traces/log index;
• billing integration - future extension point для resource usage accounting.

Security

• События не содержат secret values.
• URI артефактов должны быть refs, а не signed download URLs.
• Ошибки проходят redaction.
• Payload ограничен metadata; большие outputs лежат в S3/MinIO.