plexus.cli.procedure.cloudwatch_logger module

CloudWatch Logs integration for procedure runs.

Each procedure invocation opens two log streams:

{procedure_id}/run/{invocation_run_id} - lifecycle events, tool calls, cost events {procedure_id}/llm-context/{invocation_run_id} - full JSON per LLM call (prompt_context)

Log group: /plexus/procedures/{account_key}

All methods degrade gracefully when AWS is not configured; they never raise.

class plexus.cli.procedure.cloudwatch_logger.ProcedureCloudWatchLogger(account_key: str, procedure_id: str, invocation_run_id: str)

Bases: object

Streams procedure execution events to two CloudWatch log streams.

__init__(account_key: str, procedure_id: str, invocation_run_id: str) → None

close(success: bool = True) → None

log_llm_context(payload: Dict[str, Any]) → None

log_run_event_from_tactus(event: Any) → None

open() → None