primus.console package

Console chat runtime helpers.

Submodules

• primus.console.chat_runtime module
  • ConsoleMessage
    • ConsoleMessage.__init__()
    • ConsoleMessage.account_id
    • ConsoleMessage.client_send_started_at
    • ConsoleMessage.content
    • ConsoleMessage.created_at
    • ConsoleMessage.human_interaction
    • ConsoleMessage.id
    • ConsoleMessage.message_type
    • ConsoleMessage.metadata
    • ConsoleMessage.privacy_owner_user_id
    • ConsoleMessage.privacy_span_id
    • ConsoleMessage.private
    • ConsoleMessage.procedure_id
    • ConsoleMessage.response_status
    • ConsoleMessage.response_target
    • ConsoleMessage.role
    • ConsoleMessage.selected_model
    • ConsoleMessage.session_id
    • ConsoleMessage.session_scope
    • ConsoleMessage.tool_access_mode
  • build_response_owner()
  • claim_message()
  • console_async_tasks_available()
  • fetch_assistant_chat_messages_between()
  • fetch_chat_session()
  • fetch_first_assistant_chunk_details()
  • fetch_first_assistant_chunk_timestamp()
  • fetch_latest_report_task()
  • fetch_latest_score_edit_audit()
  • fetch_message()
  • fetch_recent_user_chat_turns()
  • fetch_session_history()
  • mark_message_completed()
  • mark_message_failed()
  • maybe_auto_title_session()
  • normalize_response_target()
  • parse_chat_message()
  • process_console_message()
  • process_pending_local_messages()
  • resolve_console_tool_access_mode()
  • run_console_chat_response()
  • run_console_chat_response_async()
  • should_handle_message()
  • update_chat_session_title()
  • utc_now()
  • warm_console_runtime()
• primus.console.local_worker module
  • main()
• primus.console.test_chat_runtime module
  • FakeClient
    • FakeClient.__init__()
    • FakeClient.execute()
  • FakeHistoryClient
    • FakeHistoryClient.__init__()
    • FakeHistoryClient.execute()
  • FakePendingClient
    • FakePendingClient.__init__()
    • FakePendingClient.execute()
  • FakeRaisingClaimClient
    • FakeRaisingClaimClient.execute()
  • FakeSessionMetadataClient
    • FakeSessionMetadataClient.__init__()
    • FakeSessionMetadataClient.execute()
  • FakeSessionTitleClient
    • FakeSessionTitleClient.__init__()
    • FakeSessionTitleClient.execute()
  • test_claim_message_uses_conditional_pending_to_running_update()
  • test_console_async_tasks_available_respects_explicit_false()
  • test_console_message_metadata_snapshots_tool_mode_and_private()
  • test_console_tool_mode_message_snapshot_overrides_session()
  • test_console_tool_mode_uses_session_metadata_when_message_has_no_snapshot()
  • test_duplicate_claim_exception_returns_false()
  • test_duplicate_claim_returns_false_without_running_response()
  • test_fetch_first_assistant_chunk_details_includes_model_and_tokens()
  • test_fetch_session_history_excludes_private_messages_from_public_context()
  • test_fetch_session_history_filters_and_sorts_messages()
  • test_fetch_session_history_includes_same_owner_private_context()
  • test_fetch_session_history_limits_to_recent_messages_and_clips_content()
  • test_fetch_session_history_retains_short_evidence_reply_for_immediate_followup()
  • test_generate_session_title_with_llm_prefers_names_over_ids()
  • test_maybe_auto_title_session_ignores_private_user_turns()
  • test_maybe_auto_title_session_replaces_title_on_second_user_turn()
  • test_maybe_auto_title_session_respects_manual_title_lock()
  • test_maybe_auto_title_session_sets_title_on_first_user_turn()
  • test_maybe_auto_title_session_skips_third_and_later_turns()
  • test_model_ids_match_ignores_provider_prefix()
  • test_parse_chat_message_defaults_missing_response_target_to_cloud()
  • test_parse_chat_message_extracts_private_owner_and_span_metadata()
  • test_parse_chat_message_extracts_selected_model_from_metadata()
  • test_parse_chat_message_ignores_non_object_metadata()
  • test_process_console_message_falls_back_to_trigger_created_at()
  • test_process_console_message_ignores_auto_title_failures()
  • test_process_console_message_ignores_local_target_for_cloud_worker()
  • test_process_console_message_logs_latency_summary()
  • test_process_console_message_marks_completed_before_auto_title()
  • test_process_console_message_marks_failed_when_harness_raises()
  • test_process_console_message_reuses_directly_fetched_trigger_message()
  • test_process_console_message_runs_harness_and_marks_completed()
  • test_process_pending_local_messages_paginates_until_limit()
  • test_process_pending_local_messages_uses_response_status_sort_key()
  • test_run_console_chat_response_passes_console_context_to_builtin()
  • test_run_console_chat_response_passes_durable_unpromoted_edit_state()
  • test_run_console_chat_response_passes_selected_model_override()
  • test_run_console_chat_response_passes_session_score_scope_to_builtin()
  • test_run_console_chat_response_skips_empty_followup_state_on_first_turn()
  • test_run_console_chat_response_uses_session_scope_fetched_with_direct_message()
  • test_score_edit_audit_from_metadata_reads_persisted_audit()
  • test_should_handle_only_matching_pending_user_chat_message()
  • test_should_handle_rejects_non_chat_message_shapes()
  • test_warm_console_runtime_prepares_mcp_server_and_prewarms_default_agent()
• primus.console.test_local_worker module
  • test_continuous_worker_logs_compact_warning_and_backs_off()
  • test_once_worker_preserves_exception_traceback_behavior()
  • test_summarize_exception_collapses_and_truncates_long_messages()