plexus.cli.procedure package

Subpackages

• plexus.cli.procedure.lua_dsl package
  • LuaDSLRuntime
    • LuaDSLRuntime.__init__()
    • LuaDSLRuntime.execute()
    • LuaDSLRuntime.get_iteration_count()
    • LuaDSLRuntime.get_state()
    • LuaDSLRuntime.is_stopped()
  • Subpackages
    • plexus.cli.procedure.lua_dsl.primitives package
      • AgentPrimitive
      • HumanPrimitive
      • IterationsPrimitive
      • StatePrimitive
      • StopPrimitive
      • SystemPrimitive
      • ToolPrimitive
      • Submodules
  • Submodules
    • plexus.cli.procedure.lua_dsl.execution_context module
      • ExecutionContext
      • GraphQLServiceAdapter
      • HumanResponse
      • LocalExecutionContext
      • ProcedureWaitingForHuman
    • plexus.cli.procedure.lua_dsl.lua_sandbox module
      • LuaSandbox
      • LuaSandboxError
    • plexus.cli.procedure.lua_dsl.output_validator module
      • OutputValidationError
      • OutputValidator
    • plexus.cli.procedure.lua_dsl.runtime module
      • LuaDSLRuntime
      • LuaDSLRuntimeError
    • plexus.cli.procedure.lua_dsl.test_runtime_basic module
      • main()
      • test_agent_model_override_rejects_non_object_context()
      • test_agent_model_override_resolution()
      • test_control_primitives()
      • test_expand_allowed_tool_names_for_plexus_alias()
      • test_full_workflow()
      • test_lua_sandbox()
      • test_state_primitive()
      • test_tool_primitive()
      • test_yaml_parser()
    • plexus.cli.procedure.lua_dsl.test_runtime_failure_session_status module
      • test_runtime_marks_chat_session_failed_when_execution_errors()
    • plexus.cli.procedure.lua_dsl.yaml_parser module
      • ProcedureConfigError
      • ProcedureYAMLParser
• plexus.cli.procedure.tactus_adapters package
  • PlexusChatAdapter
    • PlexusChatAdapter.__init__()
    • PlexusChatAdapter.end_session()
    • PlexusChatAdapter.get_session_history()
    • PlexusChatAdapter.record_message()
    • PlexusChatAdapter.start_session()
  • PlexusHITLAdapter
    • PlexusHITLAdapter.__init__()
    • PlexusHITLAdapter.cancel_pending_request()
    • PlexusHITLAdapter.check_pending_response()
    • PlexusHITLAdapter.request_interaction()
  • PlexusStorageAdapter
    • PlexusStorageAdapter.__init__()
    • PlexusStorageAdapter.checkpoint_clear_after()
    • PlexusStorageAdapter.checkpoint_clear_all()
    • PlexusStorageAdapter.checkpoint_exists()
    • PlexusStorageAdapter.checkpoint_get()
    • PlexusStorageAdapter.checkpoint_save()
    • PlexusStorageAdapter.get_state()
    • PlexusStorageAdapter.load_procedure_metadata()
    • PlexusStorageAdapter.save_procedure_metadata()
    • PlexusStorageAdapter.set_state()
    • PlexusStorageAdapter.state_clear()
    • PlexusStorageAdapter.state_delete()
    • PlexusStorageAdapter.state_get()
    • PlexusStorageAdapter.state_set()
    • PlexusStorageAdapter.update_procedure_status()
  • PlexusTraceSink
    • PlexusTraceSink.STREAM_UPDATE_MAX_INTERVAL_SECONDS
    • PlexusTraceSink.STREAM_UPDATE_MIN_CHARS_DELTA
    • PlexusTraceSink.__init__()
    • PlexusTraceSink.end_session()
    • PlexusTraceSink.flush()
    • PlexusTraceSink.mark_runtime_execute_started()
    • PlexusTraceSink.record()
    • PlexusTraceSink.start_session()
  • TerminalHITLAdapter
    • TerminalHITLAdapter.__init__()
    • TerminalHITLAdapter.request_interaction()
  • Submodules
    • plexus.cli.procedure.tactus_adapters.chat module
      • PlexusChatAdapter
    • plexus.cli.procedure.tactus_adapters.hitl module
      • PlexusHITLAdapter
    • plexus.cli.procedure.tactus_adapters.rubric_memory_toolset module
      • register_on_transport()
    • plexus.cli.procedure.tactus_adapters.score_editor_toolset module
      • ScoreEditorToolset
    • plexus.cli.procedure.tactus_adapters.storage module
      • PlexusStorageAdapter
    • plexus.cli.procedure.tactus_adapters.terminal_hitl module
      • TerminalHITLAdapter
    • plexus.cli.procedure.tactus_adapters.trace module
      • PlexusTraceSink

Submodules

• plexus.cli.procedure.builtin_procedures module
  • BuiltinProcedureSpec
    • BuiltinProcedureSpec.__init__()
    • BuiltinProcedureSpec.description
    • BuiltinProcedureSpec.name
    • BuiltinProcedureSpec.procedure_id
    • BuiltinProcedureSpec.tac_path
    • BuiltinProcedureSpec.version
  • get_builtin_procedure_spec()
  • get_builtin_procedure_yaml()
  • is_builtin_procedure_id()
• plexus.cli.procedure.chat_recorder module
  • LangChainChatRecorderHook
    • LangChainChatRecorderHook.__init__()
    • LangChainChatRecorderHook.record_agent_step()
  • ProcedureChatRecorder
    • ProcedureChatRecorder.__init__()
    • ProcedureChatRecorder.end_session()
    • ProcedureChatRecorder.get_console_session_history()
    • ProcedureChatRecorder.get_latest_console_chat_metadata()
    • ProcedureChatRecorder.get_latest_console_trigger_message()
    • ProcedureChatRecorder.get_steering_messages()
    • ProcedureChatRecorder.record_assistant_message()
    • ProcedureChatRecorder.record_message()
    • ProcedureChatRecorder.record_message_sync()
    • ProcedureChatRecorder.record_message_with_sequence()
    • ProcedureChatRecorder.record_system_message()
    • ProcedureChatRecorder.record_tool_call()
    • ProcedureChatRecorder.record_tool_response()
    • ProcedureChatRecorder.record_user_message()
    • ProcedureChatRecorder.start_session()
    • ProcedureChatRecorder.update_message()
    • ProcedureChatRecorder.update_session_name()
  • truncate_for_log()
• plexus.cli.procedure.cloudwatch_logger module
  • ProcedureCloudWatchLogger
    • ProcedureCloudWatchLogger.__init__()
    • ProcedureCloudWatchLogger.close()
    • ProcedureCloudWatchLogger.log_llm_context()
    • ProcedureCloudWatchLogger.log_run_event_from_tactus()
    • ProcedureCloudWatchLogger.open()
• plexus.cli.procedure.continuation_service module
  • build_continuation_context()
  • prepare_branch()
  • prepare_continuation()
• plexus.cli.procedure.conversation_filter module
  • ConversationFilter
    • ConversationFilter.filter_conversation()
  • ConversationFilterBase
    • ConversationFilterBase.__init__()
    • ConversationFilterBase.analyze_conversation_tokens()
  • ManagerAgentConversationFilter
    • ManagerAgentConversationFilter.__init__()
    • ManagerAgentConversationFilter.filter_conversation()
  • SOPAgentConversationFilter
    • SOPAgentConversationFilter.__init__()
    • SOPAgentConversationFilter.filter_conversation()
  • TokenAwareConversationFilter
    • TokenAwareConversationFilter.__init__()
    • TokenAwareConversationFilter.filter_conversation()
  • WorkerAgentConversationFilter
    • WorkerAgentConversationFilter.filter_conversation()
• plexus.cli.procedure.conversation_utils module
  • ConversationUtils
    • ConversationUtils.filter_conversation_history_for_model()
• plexus.cli.procedure.logging_utils module
  • capture_llm_context_for_agent()
  • capture_tactus_dspy_context_for_agent()
  • log_agent_response()
  • log_chat_history_for_agent()
  • log_filtered_vs_full_history()
  • log_tool_execution()
  • reduce_debug_noise()
  • truncate_log_message()
• plexus.cli.procedure.mcp_adapter module
  • LangChainMCPAdapter
    • LangChainMCPAdapter.__init__()
    • LangChainMCPAdapter.load_tools()
  • convert_mcp_tools_to_langchain()
• plexus.cli.procedure.mcp_tool module
  • MCPTool
    • MCPTool.args_schema
    • MCPTool.arun()
    • MCPTool.description
    • MCPTool.func
    • MCPTool.model_config
    • MCPTool.name
    • MCPTool.run()
• plexus.cli.procedure.mcp_transport module
  • EmbeddedMCPServer
    • EmbeddedMCPServer.__init__()
    • EmbeddedMCPServer.connect()
    • EmbeddedMCPServer.register_plexus_tools()
  • InProcessMCPTransport
    • InProcessMCPTransport.__init__()
    • InProcessMCPTransport.call_tool()
    • InProcessMCPTransport.initialize()
    • InProcessMCPTransport.list_resources()
    • InProcessMCPTransport.list_tools()
    • InProcessMCPTransport.read_resource()
    • InProcessMCPTransport.register_resource()
    • InProcessMCPTransport.register_tool()
  • MCPResourceInfo
    • MCPResourceInfo.__init__()
    • MCPResourceInfo.description
    • MCPResourceInfo.handler
    • MCPResourceInfo.mime_type
    • MCPResourceInfo.name
    • MCPResourceInfo.uri
  • MCPToolInfo
    • MCPToolInfo.__init__()
    • MCPToolInfo.description
    • MCPToolInfo.handler
    • MCPToolInfo.input_schema
    • MCPToolInfo.name
  • ProcedureMCPClient
    • ProcedureMCPClient.__init__()
    • ProcedureMCPClient.call_tool()
    • ProcedureMCPClient.list_resources()
    • ProcedureMCPClient.list_tools()
    • ProcedureMCPClient.read_resource()
  • create_procedure_mcp_server()
• plexus.cli.procedure.model_config module
  • ModelConfig
    • ModelConfig.__init__()
    • ModelConfig.create_langchain_llm()
    • ModelConfig.from_dict()
    • ModelConfig.max_tokens
    • ModelConfig.model
    • ModelConfig.model_kwargs
    • ModelConfig.openai_api_key
    • ModelConfig.reasoning_effort
    • ModelConfig.stream
    • ModelConfig.temperature
    • ModelConfig.to_langchain_kwargs()
    • ModelConfig.verbosity
  • ModelConfigs
    • ModelConfigs.from_environment()
    • ModelConfigs.gpt_4o_default()
    • ModelConfigs.gpt_4o_precise()
    • ModelConfigs.gpt_5_default()
    • ModelConfigs.gpt_5_high_reasoning()
    • ModelConfigs.gpt_5_mini_fast()
  • create_configured_llm()
• plexus.cli.procedure.parameter_parser module
  • ParameterDefinition
    • ParameterDefinition.__init__()
    • ParameterDefinition.default
    • ParameterDefinition.label
    • ParameterDefinition.name
    • ParameterDefinition.options
    • ParameterDefinition.required
    • ParameterDefinition.type
  • ProcedureParameterParser
    • ProcedureParameterParser.extract_parameter_values()
    • ProcedureParameterParser.get_required_parameters()
    • ProcedureParameterParser.parse_parameter_definitions()
    • ProcedureParameterParser.validate_parameter_values()
• plexus.cli.procedure.procedure_executor module
  • ProcedureExecutionCancelled
  • execute_procedure()
• plexus.cli.procedure.procedures module
• plexus.cli.procedure.reset_service module
  • clone_state_for_branch()
  • reset_checkpoints()
  • reset_checkpoints_only()
• plexus.cli.procedure.resume_service module
  • resume_all_pending()
  • resume_procedure()
• plexus.cli.procedure.service module
  • ProcedureCreationResult
    • ProcedureCreationResult.__init__()
    • ProcedureCreationResult.message
    • ProcedureCreationResult.procedure
    • ProcedureCreationResult.success
  • ProcedureInfo
    • ProcedureInfo.__init__()
    • ProcedureInfo.procedure
    • ProcedureInfo.score_name
    • ProcedureInfo.scorecard_name
  • ProcedureService
    • ProcedureService.__init__()
    • ProcedureService.create_procedure()
    • ProcedureService.delete_procedure()
    • ProcedureService.get_experiment_yaml()
    • ProcedureService.get_or_create_default_template()
    • ProcedureService.get_procedure_info()
    • ProcedureService.get_procedure_yaml()
    • ProcedureService.list_procedures()
    • ProcedureService.run_procedure()
    • ProcedureService.test_procedure_specs()
    • ProcedureService.update_procedure_config()
• plexus.cli.procedure.stale_timeout module
  • launch_async_stale_timeout_scan()
  • timeout_stale_procedures()
• plexus.cli.procedure.state_machine module
  • ProcedureStateMachine
    • ProcedureStateMachine.__init__()
    • ProcedureStateMachine.analyze
    • ProcedureStateMachine.analyze_results
    • ProcedureStateMachine.begin
    • ProcedureStateMachine.completed
    • ProcedureStateMachine.continue_iteration
    • ProcedureStateMachine.error
    • ProcedureStateMachine.evaluation
    • ProcedureStateMachine.fail_from_evaluation
    • ProcedureStateMachine.fail_from_hypothesis
    • ProcedureStateMachine.fail_from_insights
    • ProcedureStateMachine.fail_from_start
    • ProcedureStateMachine.fail_from_test
    • ProcedureStateMachine.final_states
    • ProcedureStateMachine.finish_from_hypothesis
    • ProcedureStateMachine.finish_from_insights
    • ProcedureStateMachine.hypothesis
    • ProcedureStateMachine.id
    • ProcedureStateMachine.initial_state
    • ProcedureStateMachine.insights
    • ProcedureStateMachine.name
    • ProcedureStateMachine.on_analyze()
    • ProcedureStateMachine.on_analyze_results()
    • ProcedureStateMachine.on_begin()
    • ProcedureStateMachine.on_continue_iteration()
    • ProcedureStateMachine.on_enter_error()
    • ProcedureStateMachine.on_finish_from_hypothesis()
    • ProcedureStateMachine.on_finish_from_insights()
    • ProcedureStateMachine.on_restart_from_error()
    • ProcedureStateMachine.on_retry_from_error()
    • ProcedureStateMachine.on_start_testing()
    • ProcedureStateMachine.prepare
    • ProcedureStateMachine.restart_from_error
    • ProcedureStateMachine.retry_from_error
    • ProcedureStateMachine.start
    • ProcedureStateMachine.start_testing
    • ProcedureStateMachine.state_value
    • ProcedureStateMachine.states
    • ProcedureStateMachine.states_map
    • ProcedureStateMachine.test
  • create_state_machine()
  • get_valid_transitions()
  • is_valid_transition()
• plexus.cli.procedure.state_machine_stages module
  • get_alignment_optimizer_stage_configs()
  • get_stage_names_from_state_machine()
  • get_stages_from_state_machine()
  • parse_state_machine_from_yaml()
• plexus.cli.procedure.states module
  • get_next_states()
  • is_valid_state()
  • is_valid_transition()
• plexus.cli.procedure.test_builtin_procedures module
  • test_builtin_console_procedure_prompt_teaches_docs_primitives()
  • test_builtin_console_procedure_version_is_current()
  • test_builtin_console_procedure_yaml_contains_tactus_source()
  • test_builtin_storage_adapter_uses_in_memory_metadata()
  • test_is_builtin_procedure_id()
  • test_run_procedure_builtin_passes_console_context_overrides()
  • test_run_procedure_builtin_routes_to_tactus_executor()
  • test_run_procedure_builtin_skips_mcp_server_when_disabled()
  • test_service_get_procedure_yaml_uses_builtin_without_db_lookup()
• plexus.cli.procedure.test_chat_recorder_account_resolution module
  • test_end_session_supports_legacy_status_positional_call()
  • test_end_session_supports_tactus_signature_with_session_id()
  • test_get_console_session_history_merges_truncated_snapshot_with_db()
  • test_get_console_session_history_prefers_db_when_snapshot_lacks_assistant_context()
  • test_get_console_session_history_prefers_snapshot_over_db_when_both_exist()
  • test_get_console_session_history_returns_filtered_messages()
  • test_get_console_session_history_uses_client_snapshot_when_server_history_is_stale()
  • test_get_latest_console_trigger_message_prefers_dispatch_task()
  • test_get_latest_console_trigger_message_prefers_inline_trigger_content()
  • test_get_latest_console_trigger_message_returns_chat_content()
  • test_get_latest_console_trigger_message_uses_dispatch_task_when_account_context_mismatches()
  • test_get_steering_messages_returns_completed_flat_filtered_rows()
  • test_get_steering_messages_returns_flat_filtered_rows()
  • test_record_message_injects_optimizer_bot_attribution_for_runtime_user_chat()
  • test_record_message_preserves_existing_user_attribution_metadata()
  • test_record_message_uses_chat_stream_retry_policy()
  • test_resolve_account_id_falls_back_to_client_resolver()
  • test_resolve_account_id_prefers_context()
  • test_resolve_account_id_uses_procedure_record()
  • test_start_session_creates_console_category_when_console_trigger_missing_session_id()
  • test_start_session_ignores_stale_console_metadata_when_latest_task_is_not_console()
  • test_start_session_prefers_dispatch_task_console_metadata()
  • test_start_session_reuses_console_session_from_task_metadata()
  • test_start_session_reuses_explicit_console_session_from_context()
  • test_start_session_reuses_waiting_session_and_continues_sequence()
  • test_start_session_sets_optimizer_name_on_create()
  • test_start_session_updates_existing_optimizer_session_name_when_blank()
  • test_start_session_uses_dispatch_task_console_metadata_when_account_resolution_is_stale()
• plexus.cli.procedure.test_continuation_service module
  • test_build_continuation_context_recovers_baseline_params_and_state_ids()
  • test_build_continuation_context_uses_names_when_ids_missing()
• plexus.cli.procedure.test_feedback_alignment_optimizer_config module
  • test_optimizer_baseline_feedback_runs_score_rubric_consistency_check()
  • test_optimizer_contradictions_reports_use_active_score_version_cache_key()
  • test_optimizer_creative_cookbook_is_isolated_to_creative_lane()
  • test_optimizer_normal_cookbook_emphasizes_rubric_policy_before_mechanics()
  • test_optimizer_skill_documents_three_phase_rubric_memory_sop()
  • test_optimizer_sme_gate_refreshes_rubric_memory_for_active_version()
  • test_optimizer_startup_requests_recent_rubric_memory()
  • test_optimizer_startup_requests_retrieval_only_rubric_memory()
  • test_optimizer_structural_cookbook_includes_late_prompt_shape_lane()
  • test_optimizer_yaml_adds_creative_hypothesis_after_third_cycle()
  • test_optimizer_yaml_adds_report_phase_markers_for_context_capture()
  • test_optimizer_yaml_avoids_double_counting_after_cycle_record_and_formats_cycle_prompt_with_cycle_number()
  • test_optimizer_yaml_bounds_report_context_and_output_shapes()
  • test_optimizer_yaml_caps_hypothesis_slots_by_requested_num_candidates()
  • test_optimizer_yaml_deduplicates_submitted_candidate_records()
  • test_optimizer_yaml_defines_dedicated_reporting_agents()
  • test_optimizer_yaml_defines_safe_encode_for_score_test_failure_details()
  • test_optimizer_yaml_escalates_plateaus_instead_of_stopping_or_shrinking()
  • test_optimizer_yaml_gates_sme_questions_with_rubric_memory()
  • test_optimizer_yaml_handles_semantically_unchanged_submit_errors()
  • test_optimizer_yaml_ignores_code_editor_prose_after_terminal_tools()
  • test_optimizer_yaml_keeps_bold_lane_and_uses_escalation_advisor()
  • test_optimizer_yaml_marks_one_cycle_runs_as_verification_only()
  • test_optimizer_yaml_marks_report_failures_as_terminal_without_losing_cycle_state()
  • test_optimizer_yaml_never_promotes_champion_and_reports_manual_follow_up()
  • test_optimizer_yaml_passes_code_editor_context_inline_without_history_injection()
  • test_optimizer_yaml_preprocessing_guidance_starts_with_broad_relevant_windows()
  • test_optimizer_yaml_rebaselines_continuations_when_feedback_target_advanced()
  • test_optimizer_yaml_records_sample_size_diagnostics()
  • test_optimizer_yaml_rejects_non_completed_evaluation_handles()
  • test_optimizer_yaml_rejects_repeated_strongly_harmful_hypothesis_territory()
  • test_optimizer_yaml_routes_report_generation_to_reporting_agents()
  • test_optimizer_yaml_runs_contradictions_directly_without_background_dispatch()
  • test_optimizer_yaml_skips_invalid_synthesis_strategy_selection()
  • test_optimizer_yaml_skips_synthesis_when_no_hypothesis_has_positive_signal()
  • test_optimizer_yaml_treats_cycle_errors_as_terminal_and_does_not_extend_iteration_cap()
  • test_optimizer_yaml_treats_interruption_as_terminal_not_retryable()
  • test_optimizer_yaml_uses_central_agent_steering_not_mailbox_polling()
  • test_optimizer_yaml_uses_dedicated_hypothesis_planner_and_agent_model_overrides()
  • test_optimizer_yaml_uses_lane_specific_cookbooks()
  • test_optimizer_yaml_uses_required_report_phase_helper_for_all_report_llm_calls()
  • test_optimizer_yaml_uses_safe_tool_call_arg_helper_instead_of_direct_args_dereferences()
  • test_optimizer_yaml_uses_shared_score_version_test_tool()
  • test_optimizer_yaml_uses_utf8_safe_truncation_without_byte_slicing()
• plexus.cli.procedure.test_insights_hypothesis_transition module
  • test_continue_iteration_callback()
  • test_full_insights_to_hypothesis_cycle()
  • test_hypothesis_phase_after_insights()
  • test_insights_can_finish_or_continue()
  • test_insights_to_hypothesis_transition_exists()
  • test_state_machine_transition_map_includes_insights_to_hypothesis()
• plexus.cli.procedure.test_mcp_transport module
  • TestConvenienceFunctions
    • TestConvenienceFunctions.test_create_procedure_mcp_server_basic()
    • TestConvenienceFunctions.test_create_procedure_mcp_server_with_tools()
  • TestEmbeddedMCPServer
    • TestEmbeddedMCPServer.experiment_context()
    • TestEmbeddedMCPServer.server()
    • TestEmbeddedMCPServer.test_connection_context_manager()
    • TestEmbeddedMCPServer.test_connection_default_client_info()
    • TestEmbeddedMCPServer.test_core_tool_get_context()
    • TestEmbeddedMCPServer.test_core_tool_log_message()
    • TestEmbeddedMCPServer.test_register_plexus_tools_includes_get_documentation()
    • TestEmbeddedMCPServer.test_server_initialization()
  • TestInProcessMCPTransport
    • TestInProcessMCPTransport.sample_resource()
    • TestInProcessMCPTransport.sample_tool()
    • TestInProcessMCPTransport.test_call_tool_error_handling()
    • TestInProcessMCPTransport.test_call_tool_not_found()
    • TestInProcessMCPTransport.test_call_tool_not_initialized()
    • TestInProcessMCPTransport.test_call_tool_success()
    • TestInProcessMCPTransport.test_initialize_connection()
    • TestInProcessMCPTransport.test_list_resources()
    • TestInProcessMCPTransport.test_list_tools()
    • TestInProcessMCPTransport.test_read_resource_not_found()
    • TestInProcessMCPTransport.test_read_resource_success()
    • TestInProcessMCPTransport.test_resource_registration()
    • TestInProcessMCPTransport.test_tool_registration()
    • TestInProcessMCPTransport.test_transport_initialization()
    • TestInProcessMCPTransport.transport()
  • TestIntegrationScenarios
    • TestIntegrationScenarios.test_error_handling_workflow()
    • TestIntegrationScenarios.test_full_experiment_mcp_workflow()
  • TestProcedureMCPClient
    • TestProcedureMCPClient.client()
    • TestProcedureMCPClient.initialized_client()
    • TestProcedureMCPClient.test_client_call_tool()
    • TestProcedureMCPClient.test_client_list_resources()
    • TestProcedureMCPClient.test_client_list_tools()
    • TestProcedureMCPClient.transport()
  • test_advance_task_to_stage_by_name_uses_long_running_retry_policy()
  • test_update_stage_progress_uses_long_running_retry_policy()
• plexus.cli.procedure.test_phase_agent module
  • TestPhaseAgent
    • TestPhaseAgent.__init__()
    • TestPhaseAgent.cleanup()
    • TestPhaseAgent.execute()
• plexus.cli.procedure.test_procedure_executor_compat module
  • test_console_tactus_bridges_mcp_tools_into_toolset_registry()
  • test_execute_tactus_applies_child_depth_budget_to_runtime_source()
  • test_execute_tactus_completes_stages_only_on_success()
  • test_execute_tactus_does_not_duplicate_response_when_trace_already_has_same_assistant_text()
  • test_execute_tactus_does_not_record_result_response_when_trace_has_different_assistant_text()
  • test_execute_tactus_fails_when_child_budget_cost_is_exceeded()
  • test_execute_tactus_hydrates_context_from_params_values()
  • test_execute_tactus_initializes_embedded_mcp_transport()
  • test_execute_tactus_injects_console_session_history_into_runtime_context()
  • test_execute_tactus_injects_console_trigger_message_into_runtime_context()
  • test_execute_tactus_marks_stages_failed_when_runtime_raises()
  • test_execute_tactus_marks_stages_failed_when_runtime_returns_failure()
  • test_execute_tactus_marks_stages_failed_when_runtime_returns_wrapped_failure()
  • test_execute_tactus_passes_chat_recorder_when_supported()
  • test_execute_tactus_persists_inference_costs_from_cost_events()
  • test_execute_tactus_records_result_response_when_trace_has_no_assistant_messages()
  • test_execute_tactus_sets_chat_recorder_account_id_from_runtime_context()
  • test_execute_tactus_skips_chat_recorder_console_lookups_when_context_provides_values()
  • test_execute_tactus_stops_before_runtime_when_task_cancelled()
  • test_execute_tactus_streams_via_log_handler_without_trace_sink_constructor()
  • test_execute_tactus_supports_legacy_runtime_without_trace_sink()
  • test_execute_tactus_synthesizes_assistant_message_for_legacy_chat_runtime()
  • test_scorecard_create_dry_run_skips_approval()
  • test_trace_bridge_forwards_cost_events_to_trace_sink()
• plexus.cli.procedure.test_procedure_optimize_cli_result module
  • LuaTableLike
    • LuaTableLike.__init__()
    • LuaTableLike.items()
    • LuaTableLike.keys()
    • LuaTableLike.values()
  • test_lua_to_python_converts_contiguous_one_based_tables_to_lists()
  • test_lua_to_python_converts_nested_iterations_to_list()
  • test_lua_to_python_preserves_non_contiguous_numeric_key_dicts()
  • test_lua_to_python_preserves_string_key_dicts()
  • test_optimize_table_summary_handles_lua_style_iteration_result()
• plexus.cli.procedure.test_reset_service module
  • test_clone_state_for_branch_clears_costs_and_runtime_mailbox_state()
• plexus.cli.procedure.test_score_editor_toolset module
  • FakeMCPClient
    • FakeMCPClient.__init__()
    • FakeMCPClient.call_tool()
  • FakePullMCPClient
    • FakePullMCPClient.__init__()
    • FakePullMCPClient.call_tool()
  • test_load_content_from_api_fails_clearly_on_invalid_yaml()
  • test_load_content_from_api_normalizes_yaml_before_exposing_it()
  • test_setup_fails_fast_when_direct_yaml_is_invalid()
  • test_setup_normalizes_direct_yaml_content_to_block_scalars()
  • test_setup_normalizes_numeric_external_id_to_string()
  • test_submit_score_version_allows_extractor_then_classifier_pattern()
  • test_submit_score_version_rejects_classifier_as_extractor_candidate()
  • test_submit_score_version_rejects_semantically_unchanged_yaml()
  • test_submit_score_version_surfaces_validation_errors_from_envelope()
• plexus.cli.procedure.test_service_actor_attribution module
  • test_run_evaluation_for_procedure_passes_parent_client_and_account()
  • test_run_procedure_builtin_wraps_execution_with_runtime_actor_context()
• plexus.cli.procedure.test_service_yaml_loader module
  • test_get_procedure_yaml_loads_s3_code_when_metadata_is_dict()
• plexus.cli.procedure.test_spec_runner_service module
  • service()
  • test_acceptance_procedure_specs_pass_in_mock_mode()
  • test_spec_runner_fails_on_invalid_yaml()
  • test_spec_runner_fails_when_code_missing()
  • test_spec_runner_fails_when_no_spec_block()
  • test_spec_runner_loads_yaml_from_procedure_id()
  • test_spec_runner_propagates_integration_mode()
  • test_spec_runner_runs_embedded_specs_from_yaml()
• plexus.cli.procedure.test_stale_timeout module
  • test_timeout_stale_procedures_continues_when_procedure_update_conflicts()
  • test_timeout_stale_procedures_excludes_runs_started_before_lookback()
  • test_timeout_stale_procedures_marks_chat_silent_run_stalled()
  • test_timeout_stale_procedures_skips_foreign_host_runtime_when_activity_is_stale()
  • test_timeout_stale_procedures_skips_fresh_chat_activity()
  • test_timeout_stale_procedures_skips_stale_chat_when_runtime_heartbeat_is_fresh()
  • test_timeout_stale_procedures_skips_waiting_for_human()
  • test_timeout_stale_procedures_skips_when_local_runtime_process_is_active()
  • test_timeout_stale_procedures_times_out_no_chat_when_started_is_stale()
• plexus.cli.procedure.test_state_machine module
  • test_allowed_transitions_property()
  • test_callbacks_are_called()
  • test_completed_is_final_state()
  • test_error_transitions()
  • test_get_valid_transitions_from_hypothesis()
  • test_get_valid_transitions_from_start()
  • test_invalid_transition_raises_error()
  • test_is_valid_transition_helper()
  • test_recovery_from_error()
  • test_state_machine_initial_state()
  • test_state_machine_resume_from_state()
  • test_valid_transition_evaluation_to_hypothesis()
  • test_valid_transition_hypothesis_to_completed()
  • test_valid_transition_hypothesis_to_test()
  • test_valid_transition_start_to_evaluation()
  • test_valid_transition_test_to_insights()
• plexus.cli.procedure.test_storage_metadata_preservation module
  • test_save_procedure_metadata_preserves_runtime_and_failure_fields()
  • test_update_procedure_status_uses_long_running_write_policy()
• plexus.cli.procedure.test_tactus_hitl_adapter module
  • test_cancel_pending_request_uses_long_running_retry_policy()
  • test_check_pending_response_ignores_non_canonical_response_payload()
  • test_request_interaction_creates_pending_message_and_sets_waiting_status()
  • test_request_interaction_returns_response_from_existing_pending_message()
  • test_request_interaction_reuses_existing_unresolved_pending_message()
• plexus.cli.procedure.test_tactus_integration module
  • mock_plexus_client()
  • simple_lua_config()
  • test_tactus_checkpoint_persistence()
  • test_tactus_error_handling()
  • test_tactus_state_persistence()
  • test_tactus_with_plexus_adapters()
• plexus.cli.procedure.test_tool_explanation_enforcement_simple module
  • TestToolExplanationEnforcement
    • TestToolExplanationEnforcement.test_complete_enforcement_cycle_logic()
    • TestToolExplanationEnforcement.test_edge_case_no_tool_calls_in_response()
    • TestToolExplanationEnforcement.test_enforcement_prevents_tool_chaining_pattern()
    • TestToolExplanationEnforcement.test_explanation_flag_removes_tools_from_llm()
    • TestToolExplanationEnforcement.test_logging_behavior_during_enforcement()
    • TestToolExplanationEnforcement.test_multiple_tool_calls_enforcement()
    • TestToolExplanationEnforcement.test_reminder_message_injection_behavior()
    • TestToolExplanationEnforcement.test_tool_execution_sets_explanation_flag()
    • TestToolExplanationEnforcement.test_tools_restored_after_explanation()
• plexus.cli.procedure.test_trace_sink module
  • test_trace_sink_cost_events_attach_to_streamed_assistant_message()
  • test_trace_sink_does_not_attach_zero_cost_placeholder_to_assistant_message()
  • test_trace_sink_does_not_flag_successful_string_tool_output_as_failure()
  • test_trace_sink_drops_duplicate_post_stream_assistant_message()
  • test_trace_sink_drops_placeholder_assistant_completion_message()
  • test_trace_sink_ends_session_with_status()
  • test_trace_sink_late_cost_event_updates_recent_assistant_message()
  • test_trace_sink_records_assistant_alert_for_failed_tool_result()
  • test_trace_sink_records_modern_tool_call_event_shape()
  • test_trace_sink_records_tool_call_with_structured_payloads()
  • test_trace_sink_skips_dispatch_metadata_lookup_for_builtin_console_procedure()
  • test_trace_sink_skips_dispatch_metadata_lookup_when_disabled()
  • test_trace_sink_stream_chunk_upserts_single_assistant_message()
  • test_trace_sink_stream_completion_finalizes_message_and_tracks_text()
  • test_trace_sink_stream_metadata_contains_latency_markers()
  • test_trace_sink_tool_call_message_includes_tool_cost_metadata()
  • test_trace_sink_updates_started_tool_call_from_explicit_tool_response()
• plexus.cli.procedure.tool_calling module
  • call_tool()
  • extract_all_tool_calls()