fix(awooop): surface alert inbound by provider event
This commit is contained in:
@@ -1200,6 +1200,7 @@ async def fetch_truth_chain(source_id: str, project_id: str = "awoooi") -> dict[
|
||||
WHERE project_id = :project_id
|
||||
AND (
|
||||
run_id::text = :source_id
|
||||
OR provider_event_id = :source_id
|
||||
OR content_preview ILIKE :source_needle
|
||||
OR (
|
||||
:fingerprint_needle != ''
|
||||
|
||||
@@ -1,5 +1,6 @@
|
||||
from __future__ import annotations
|
||||
|
||||
import inspect
|
||||
from datetime import datetime, timedelta, timezone
|
||||
from types import SimpleNamespace
|
||||
|
||||
@@ -15,6 +16,7 @@ from src.services.awooop_truth_chain_service import (
|
||||
_incident_fingerprints,
|
||||
_summarize_gateway_mcp,
|
||||
_truth_status,
|
||||
fetch_truth_chain,
|
||||
summarize_automation_quality_records,
|
||||
)
|
||||
from src.services.drift_repeat_state import (
|
||||
@@ -51,6 +53,12 @@ def test_incident_fingerprints_reads_signal_labels() -> None:
|
||||
assert fingerprints == ["fp-direct", "fp-label"]
|
||||
|
||||
|
||||
def test_fetch_truth_chain_can_match_inbound_provider_event_id() -> None:
|
||||
source = inspect.getsource(fetch_truth_chain)
|
||||
|
||||
assert "provider_event_id = :source_id" in source
|
||||
|
||||
|
||||
def test_truth_status_marks_no_action_approval_as_manual_required() -> None:
|
||||
status = _truth_status(
|
||||
incident={"incident_id": "INC-1", "status": "INVESTIGATING"},
|
||||
|
||||
Reference in New Issue
Block a user