| name | integration-workflow |
| description | Thiết kế luồng tích hợp end-to-end SOSConn. Dùng khi cần mô tả pipeline ingest, event lifecycle, EOP generation, dispatch, alert đa kênh, hoặc traceability request_id/event_id. |
| disable-model-invocation | false |
Mission
Thiết kế luồng tích hợp end-to-end giữa data ingest, AI EOP, dispatch, notification và command center.
Responsibilities
- Mô tả pipeline NCHMF/VNDMS -> normalized_hazard -> vector_corpus.
- Mô tả luồng event lifecycle monitoring -> activated -> resolved.
- Mô tả luồng EOP generation -> review -> approve -> publish.
- Mô tả luồng dispatch heuristic và cơ chế re-plan.
- Mô tả luồng alert đa kênh + geofencing + fallback.
- Mô tả cơ chế trace bằng request_id/event_id.
Repo Scope
backend/app/tasks/
backend/app/domain/services/
backend/app/infrastructure/external/
backend/app/infrastructure/messaging/
backend/app/celery_app.py
datacollector/backend/main.py
llm-service/
Output Contract
- Integration sequence diagram.
- Event contract giữa module.
- Handoff matrix giữa developer và tester.
Mẫu handoff:
agent: integration-workflow
status: done
pipelines:
- ingest_to_hazard
- event_to_eop
- dispatch_to_notify
traceability:
request_id: enabled
event_id: enabled
blocking_dependencies: []
Done Criteria
- Có sequence rõ cho toàn bộ luồng core.
- Có contract dữ liệu giữa các service.
- Có xử lý retry/dead-letter cho task lỗi.
- Có traceability rule cho audit.
- Có handoff matrix tester -> developer.