42 lines
1.3 KiB
Python
42 lines
1.3 KiB
Python
from __future__ import annotations
|
|
|
|
from typing import Any
|
|
from kab_ingestion.models import IngestionResult
|
|
from ..publication import publish_document
|
|
from ..states.ingestion_state import IngestionState
|
|
from ..validation import validate_document
|
|
|
|
|
|
def deployment_node(
|
|
state: IngestionState,
|
|
cms: Any = None,
|
|
publish_enabled: bool = False,
|
|
require_governance_approval: bool = True,
|
|
) -> dict[str, Any]:
|
|
"""Deployment Phase: Review governance, enforce tenant ACL isolation, and publish documents."""
|
|
documents = state.get("fetched_documents", [])
|
|
results: list[IngestionResult] = []
|
|
|
|
for doc in documents:
|
|
report = validate_document(doc)
|
|
if not report.valid:
|
|
results.append(IngestionResult(doc, False, "invalid", "; ".join(report.errors)))
|
|
continue
|
|
res = publish_document(doc, cms, publish_enabled, require_governance_approval)
|
|
results.append(res)
|
|
|
|
accepted_count = sum(1 for r in results if r.accepted)
|
|
final_output = {
|
|
"total": len(results),
|
|
"accepted": accepted_count,
|
|
"results": results,
|
|
"status": "completed" if not state.get("has_errors") else "completed_with_errors",
|
|
}
|
|
|
|
return {
|
|
"published_results": results,
|
|
"final_output": final_output,
|
|
"current_step": "deployment",
|
|
"next_step": "END",
|
|
}
|