primus package

Primus: Orchestration for AI/ML classification at scale.

This package exposes many submodules. To keep imports lightweight and avoid optional heavy dependencies during package import, top‑level symbols are resolved lazily via __getattr__ when accessed.

Subpackages

• primus.agentic package
  • AlignmentOptimizer
    • AlignmentOptimizer.__init__()
    • AlignmentOptimizer.optimize()
    • AlignmentOptimizer.run_baseline_only()
  • Submodules
    • primus.agentic.alignment_optimizer module
      • AlignmentOptimizer
      • OptimizationMonitor
• primus.analysis package
  • Accuracy
    • Accuracy.calculate()
  • GwetAC1
    • GwetAC1.calculate()
  • Precision
    • Precision.__init__()
    • Precision.calculate()
  • Recall
    • Recall.__init__()
    • Recall.calculate()
  • Subpackages
    • primus.analysis.metrics package
      • Accuracy
      • GwetAC1
      • Metric
      • Precision
      • Recall
      • Submodules
    • primus.analysis.topics package
      • analyze_topics()
      • inspect_data()
      • test_ollama_chat()
      • transform_transcripts()
      • transform_transcripts_itemize()
      • transform_transcripts_llm()
      • Submodules
  • Submodules
    • primus.analysis.embedding_cache module
      • EmbeddingCache
      • EmbeddingService
      • cache_key()
      • normalize_text()
    • primus.analysis.feedback_analyzer module
      • analyze_feedback_items()
      • analyze_feedback_pair_counts()
      • build_confusion_matrix()
      • calculate_precision_recall()
      • generate_recommendation()
    • primus.analysis.memory_weights module
      • decay()
      • initial_weight()
      • reinforce()
      • should_prune()
      • tier_from_weight()
      • update_memory_weights()
    • primus.analysis.metrics package
      • Accuracy
      • GwetAC1
      • Metric
      • Precision
      • Recall
      • Submodules
    • primus.analysis.qdrant_vector_store module
      • QdrantTopicMemoryVectorStore
    • primus.analysis.s3vectors_client module
      • TopicMemoryVectorStore
    • primus.analysis.topic_clusterer module
      • TopicClusterer
    • primus.analysis.vector_store_factory module
      • create_topic_memory_vector_store()
• primus.attribution package
  • ActorContext
    • ActorContext.__init__()
    • ActorContext.actor_key
    • ActorContext.actor_source
    • ActorContext.actor_type
    • ActorContext.as_dict()
    • ActorContext.user_id
  • apply_actor_attribution()
  • apply_actor_context_to_env()
  • extract_request_user_id_from_mcp_context()
  • resolve_actor_context()
  • set_runtime_actor_context()
  • Submodules
    • primus.attribution.actor_context module
      • ActorContext
      • apply_actor_attribution()
      • apply_actor_context_to_env()
      • extract_request_user_id_from_mcp_context()
      • resolve_actor_context()
      • set_runtime_actor_context()
• primus.auth package
  • Submodules
    • primus.auth.cognito module
      • ApplicationAuthenticationRequired
      • AuthorizationRequest
      • CognitoAuthConfig
      • CognitoAuthService
      • KeyringRefreshTokenStore
      • LoopbackCallbackError
      • MissingApplicationSession
      • RefreshCredentialRejected
      • RefreshTokenStore
      • RefreshTransportFailure
      • TokenSet
    • primus.auth.test_cognito module
      • config()
      • test_access_token_is_cached_in_memory_until_near_expiry()
      • test_access_token_is_refreshed_from_keychain()
      • test_access_token_is_refreshed_when_it_is_within_the_pre_expiry_window()
      • test_configuration_discovers_hosted_authorization_from_amplify_output()
      • test_configuration_discovery_uses_the_hosted_domain_client_and_region()
      • test_configuration_explains_when_amplify_has_no_hosted_authorization_output()
      • test_configuration_rejects_any_unregistered_loopback_callback()
      • test_confirmed_invalid_grant_removes_refresh_credential_and_requires_login()
      • test_environment_configuration_overrides_amplify_output()
      • test_exchange_stores_only_refresh_token()
      • test_invalid_grant_raised_directly_by_post_removes_refresh_credential()
      • test_keyring_store_only_suppresses_the_keyring_not_found_error()
      • test_keyring_store_reports_a_real_delete_failure()
      • test_keyring_store_uses_the_os_keychain()
      • test_login_binds_loopback_listener_before_opening_browser()
      • test_login_keeps_listener_open_when_browser_does_not_launch()
      • test_login_url_uses_state_and_s256_pkce()
      • test_loopback_callback_does_not_wait_for_reverse_dns()
      • test_loopback_callback_rejects_missing_or_mismatched_state()
      • test_loopback_callback_rejects_provider_errors()
      • test_loopback_callback_reports_an_occupied_registered_port()
      • test_missing_refresh_credential_requires_login_without_a_network_refresh()
      • test_repeated_transient_refresh_failures_stop_after_the_bounded_retry()
      • test_token_exchange_failure_returns_actionable_login_guidance()
      • test_transient_refresh_failure_is_retried_before_the_command_fails()
      • test_typed_refresh_failures_remain_compatible_with_authentication_callers()
      • test_unproven_refresh_rejections_preserve_credential()
      • test_whoami_uses_non_sensitive_identity_from_current_token()
• primus.chat package
  • ChatMessageActionService
    • ChatMessageActionService.__init__()
    • ChatMessageActionService.create_or_get()
    • ChatMessageActionService.publish_update()
    • ChatMessageActionService.resolve_first_valid_response()
  • Submodules
    • primus.chat.action_service module
      • ChatMessageActionService
    • primus.chat.session_ops module
      • get_chat_message()
      • get_chat_session()
      • get_latest_chat_session()
      • list_session_messages()
      • resolve_account_id()
      • send_chat_message()
• primus.cli package
  • Subpackages
    • primus.cli.analyze package
      • Submodules
    • primus.cli.auth package
      • Submodules
    • primus.cli.batch package
      • Submodules
    • primus.cli.bertopic package
      • analyze_topics()
      • inspect_data()
      • test_ollama_chat()
      • transform_transcripts()
      • transform_transcripts_itemize()
      • transform_transcripts_llm()
    • primus.cli.chat package
      • Submodules
    • primus.cli.cost package
      • Submodules
    • primus.cli.data package
      • Submodules
    • primus.cli.data_lake package
      • Submodules
    • primus.cli.dataset package
      • Submodules
    • primus.cli.evaluation package
      • Submodules
    • primus.cli.execute package
      • Submodules
    • primus.cli.feedback package
      • Submodules
    • primus.cli.item package
      • Submodules
    • primus.cli.metrics package
      • Submodules
    • primus.cli.optimization package
      • Submodules
    • primus.cli.prediction package
      • Submodules
    • primus.cli.procedure package
      • Subpackages
      • Submodules
    • primus.cli.record_count package
      • Submodules
    • primus.cli.report package
      • Submodules
    • primus.cli.result package
      • Submodules
    • primus.cli.rubric_memory package
      • Submodules
    • primus.cli.score package
      • ScoreService
      • Submodules
    • primus.cli.score_chat package
      • Submodules
    • primus.cli.scorecard package
      • Submodules
    • primus.cli.shared package
      • Submodules
    • primus.cli.task package
      • Submodules
    • primus.cli.training package
      • Submodules
    • primus.cli.tuning package
      • Submodules
  • Submodules
    • primus.cli.CommandLineInterface module
      • main()
    • primus.cli.entrypoint module
      • main()
• primus.command_worker package
  • AuditEvent
    • AuditEvent.__init__()
    • AuditEvent.authentication_method
    • AuditEvent.command_id
    • AuditEvent.correlation_id
    • AuditEvent.event_type
    • AuditEvent.occurred_at
    • AuditEvent.outcome
    • AuditEvent.policy_version
    • AuditEvent.principal_id
    • AuditEvent.principal_type
    • AuditEvent.target
    • AuditEvent.tenant_id
  • AuditEventType
    • AuditEventType.AUTHORIZATION_DENIED
    • AuditEventType.CANCELLATION
    • AuditEventType.IDEMPOTENCY_CONFLICT
    • AuditEventType.READ
    • AuditEventType.SUBMIT_CREATED
    • AuditEventType.SUBMIT_EXISTING
  • AuditSink
    • AuditSink.__init__()
    • AuditSink.record()
  • AuthenticatedCommandContext
    • AuthenticatedCommandContext.__init__()
    • AuthenticatedCommandContext.authentication_method
    • AuthenticatedCommandContext.correlation_id
    • AuthenticatedCommandContext.principal_id
    • AuthenticatedCommandContext.principal_type
    • AuthenticatedCommandContext.tenant_id
  • AuthorizationDecision
    • AuthorizationDecision.__init__()
    • AuthorizationDecision.allowed
    • AuthorizationDecision.policy_version
  • AuthorizationDenied
    • AuthorizationDenied.__init__()
  • CancellationRequestedError
  • CancellationResult
    • CancellationResult.__init__()
    • CancellationResult.changed
    • CancellationResult.command
  • Claim
    • Claim.__init__()
    • Claim.cancellation_requested
    • Claim.expires_at
    • Claim.owner
    • Claim.token
  • ClaimStatus
    • ClaimStatus.ACTIVE
    • ClaimStatus.INTEGRITY_MISMATCH
    • ClaimStatus.TERMINAL
  • Clock
    • Clock.__init__()
    • Clock.now()
  • CommandAuthorizer
    • CommandAuthorizer.__init__()
    • CommandAuthorizer.can_cancel()
    • CommandAuthorizer.can_read()
    • CommandAuthorizer.can_submit()
  • CommandEnvelope
    • CommandEnvelope.CURRENT_SCHEMA_VERSION
    • CommandEnvelope.__init__()
    • CommandEnvelope.command_id
    • CommandEnvelope.created_at
    • CommandEnvelope.from_message()
    • CommandEnvelope.idempotency_key
    • CommandEnvelope.payload
    • CommandEnvelope.schema_version
    • CommandEnvelope.target
    • CommandEnvelope.tenant_id
    • CommandEnvelope.to_message()
  • CommandIdGenerator
    • CommandIdGenerator.__init__()
    • CommandIdGenerator.new_id()
  • CommandLimits
    • CommandLimits.__init__()
    • CommandLimits.max_idempotency_key_length
    • CommandLimits.max_identifier_length
    • CommandLimits.max_json_bytes
    • CommandLimits.max_json_containers
    • CommandLimits.max_json_depth
  • CommandNotFound
    • CommandNotFound.__init__()
  • CommandRecord
    • CommandRecord.__init__()
    • CommandRecord.command_id
    • CommandRecord.created_at
    • CommandRecord.envelope
    • CommandRecord.idempotency_key
    • CommandRecord.idempotency_namespace
    • CommandRecord.payload
    • CommandRecord.request_digest
    • CommandRecord.status
    • CommandRecord.submitted_by
    • CommandRecord.target
    • CommandRecord.tenant_id
    • CommandRecord.updated_at
  • CommandRepository
    • CommandRepository.__init__()
    • CommandRepository.announce()
    • CommandRepository.get()
    • CommandRepository.request_cancel()
  • CommandRequest
    • CommandRequest.__init__()
    • CommandRequest.idempotency_key
    • CommandRequest.payload
    • CommandRequest.target
  • CommandService
    • CommandService.__init__()
    • CommandService.cancel()
    • CommandService.get()
    • CommandService.submit()
  • CommandStatus
    • CommandStatus.ANNOUNCED
    • CommandStatus.CANCELLED
    • CommandStatus.CANCEL_REQUESTED
    • CommandStatus.FAILED
    • CommandStatus.RUNNING
    • CommandStatus.SUCCEEDED
    • CommandStatus.is_terminal
  • CommandWorker
    • CommandWorker.__init__()
    • CommandWorker.process()
  • CommandWorkerService
    • CommandWorkerService.__init__()
    • CommandWorkerService.run()
  • Delivery
    • Delivery.__init__()
    • Delivery.acknowledge()
    • Delivery.envelope
    • Delivery.extend_lease()
    • Delivery.quarantine()
    • Delivery.release()
  • DrainSignal
    • DrainSignal.__init__()
    • DrainSignal.is_requested()
    • DrainSignal.wait()
  • EventDrainSignal
    • EventDrainSignal.__init__()
    • EventDrainSignal.is_requested()
    • EventDrainSignal.request()
    • EventDrainSignal.wait()
  • ExecutionContext
    • ExecutionContext.__init__()
    • ExecutionContext.cancellation_requested
    • ExecutionContext.ownership_lost
    • ExecutionContext.raise_if_cancellation_requested()
    • ExecutionContext.raise_if_lease_lost()
    • ExecutionContext.renew_lease()
    • ExecutionContext.report_progress()
  • Executor
    • Executor.__init__()
    • Executor.execute()
  • HeartbeatHandle
    • HeartbeatHandle.__init__()
    • HeartbeatHandle.stop()
  • HeartbeatScheduler
    • HeartbeatScheduler.__init__()
    • HeartbeatScheduler.start()
  • IdempotencyConflict
    • IdempotencyConflict.__init__()
  • InMemoryCommandRepository
    • InMemoryCommandRepository.__init__()
    • InMemoryCommandRepository.announce()
    • InMemoryCommandRepository.discoverable_dispatches()
    • InMemoryCommandRepository.get()
    • InMemoryCommandRepository.request_cancel()
    • InMemoryCommandRepository.set_status()
  • LeaseLostError
  • LifecycleStore
    • LifecycleStore.__init__()
    • LifecycleStore.claim()
    • LifecycleStore.complete()
    • LifecycleStore.fail()
    • LifecycleStore.finalize_cancel()
    • LifecycleStore.renew()
    • LifecycleStore.report_progress()
  • ProcessOutcome
    • ProcessOutcome.ACTIVE_DUPLICATE
    • ProcessOutcome.CANCELLED
    • ProcessOutcome.COMPLETED
    • ProcessOutcome.FAILED
    • ProcessOutcome.INTEGRITY_MISMATCH
    • ProcessOutcome.LEASE_LOST
    • ProcessOutcome.TERMINAL_DUPLICATE
  • ProgressUpdate
    • ProgressUpdate.__init__()
    • ProgressUpdate.details
    • ProgressUpdate.fraction
    • ProgressUpdate.message
  • RequestDigest
    • RequestDigest.__init__()
    • RequestDigest.algorithm
    • RequestDigest.canonicalization_version
    • RequestDigest.value
  • ServiceOutcome
    • ServiceOutcome.__init__()
    • ServiceOutcome.count()
    • ServiceOutcome.outcome_counts
    • ServiceOutcome.process_outcomes
    • ServiceOutcome.processed_count
    • ServiceOutcome.stop_reason
  • ServiceReceiveError
    • ServiceReceiveError.__init__()
    • ServiceReceiveError.processed_count
  • ServiceStopReason
    • ServiceStopReason.DRAIN_REQUESTED
  • SubmissionDisposition
    • SubmissionDisposition.EXISTING
    • SubmissionDisposition.NEW
  • SubmissionResult
    • SubmissionResult.__init__()
    • SubmissionResult.command
    • SubmissionResult.disposition
  • ThreadHeartbeatScheduler
    • ThreadHeartbeatScheduler.__init__()
    • ThreadHeartbeatScheduler.start()
  • Transport
    • Transport.__init__()
    • Transport.receive()
  • UUIDCommandIdGenerator
    • UUIDCommandIdGenerator.new_id()
  • request_digest()
  • Subpackages
    • primus.command_worker.adapters package
      • Submodules
    • primus.command_worker.executors package
      • PrimusCliExecutor
      • Submodules
    • primus.command_worker.runtime package
      • CommandWorkerRuntimeConfig
      • main()
      • Submodules
  • Submodules
    • primus.command_worker.application module
      • AuthorizationDenied
      • CommandNotFound
      • CommandService
      • IdempotencyConflict
      • UUIDCommandIdGenerator
    • primus.command_worker.models module
      • AnnouncementDisposition
      • AnnouncementResult
      • AuditEvent
      • AuditEventType
      • AuthenticatedCommandContext
      • AuthorizationDecision
      • CancellationResult
      • Claim
      • CommandEnvelope
      • CommandLimits
      • CommandRecord
      • CommandRequest
      • CommandStatus
      • ProgressUpdate
      • RequestDigest
      • SubmissionDisposition
      • SubmissionResult
      • freeze_json()
      • request_digest()
    • primus.command_worker.ports module
      • AuditSink
      • ClaimStatus
      • Clock
      • CommandAuthorizer
      • CommandIdGenerator
      • CommandRepository
      • Delivery
      • DrainSignal
      • ExecutionContext
      • Executor
      • HeartbeatHandle
      • HeartbeatScheduler
      • LifecycleStore
      • TaskScaleInProtection
      • Transport
    • primus.command_worker.repository module
      • InMemoryCommandRepository
    • primus.command_worker.scheduler module
      • ThreadHeartbeatScheduler
    • primus.command_worker.service module
      • CommandWorkerService
      • EventDrainSignal
      • ServiceOutcome
      • ServiceReceiveError
      • ServiceStopReason
    • primus.command_worker.smoke module
      • main()
    • primus.command_worker.worker module
      • CancellationRequestedError
      • CommandWorker
      • LeaseLostError
      • ProcessOutcome
• primus.config package
  • ConfigLoader
    • ConfigLoader.CONFIG_FILENAMES
    • ConfigLoader.ENV_VAR_MAPPING
    • ConfigLoader.HOME_CONFIG_DIR
    • ConfigLoader.__init__()
    • ConfigLoader.get_available_sources()
    • ConfigLoader.get_config_value()
    • ConfigLoader.load_config()
  • load_config()
  • Submodules
    • primus.config.loader module
      • ConfigLoader
      • ConfigSource
      • load_config()
    • primus.config.test_loader module
      • TestConfigLoader
      • TestEnvironmentVariableMapping
      • TestLoadConfigFunction
• primus.console package
  • Submodules
    • primus.console.chat_runtime module
      • ConsoleMessage
      • 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
      • FakeHistoryClient
      • FakePendingClient
      • FakeRaisingClaimClient
      • FakeSessionMetadataClient
      • FakeSessionTitleClient
      • 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()
• primus.core package
  • Submodules
    • primus.core.ScoreInput module
      • ScoreInput
• primus.dashboard package
  • Subpackages
    • primus.dashboard.api package
      • Subpackages
      • Submodules
    • primus.dashboard.commands package
      • Submodules
  • Submodules
    • primus.dashboard.cli module
      • create_client()
      • generate_key()
      • simulate_evaluation_progress()
• primus.data package
  • Submodules
    • primus.data.AWSDataLakeCache module
      • AWSDataLakeCache
    • primus.data.DataCache module
      • DataCache
    • primus.data.FeedbackItems module
      • FeedbackItems
    • primus.data.HuggingFaceDataCache module
      • HuggingFaceDataCache
    • primus.data.ScorecardExampleReferenceItems module
      • ScorecardExampleReferenceItems
    • primus.data.TestDataCache module
      • TestDataCache
    • primus.data.session_manager module
      • SessionManager
    • primus.data.test_data_cache_logging module
      • test_debug_dataframe_logs_schema_without_row_payloads()
      • test_score_data_logs_schema_without_sample_rows()
    • primus.data.test_feedback_items module
      • test_cache_directory_uses_runtime_environment()
      • test_cache_identifier_with_filter_values()
      • test_cache_methods()
      • test_case_insensitive_normalization()
      • test_column_mappings_applied_to_dataset()
      • test_column_mappings_case_sensitivity()
      • test_column_mappings_parameter()
      • test_column_mappings_with_empty_dataset()
      • test_create_dataset_rows_comment_logic()
      • test_create_dataset_rows_fails_when_item_metadata_missing()
      • test_create_dataset_rows_handles_missing_edit_comment()
      • test_create_dataset_rows_skips_unresolved_labels_and_reports_ids()
      • test_create_dataset_rows_structure()
      • test_create_dataset_rows_with_data()
      • test_exact_feedback_item_ids_are_unique_and_preserve_requested_order()
      • test_exact_feedback_item_ids_fail_closed_when_membership_cannot_be_materialized()
      • test_fetch_feedback_items_for_scores_excludes_invalid_items()
      • test_initial_value_and_final_value_parameters()
      • test_parameter_defaults()
      • test_parameter_validation()
      • test_reference_label_resolution_imported_and_unresolved()
      • test_reference_label_resolution_priority()
    • primus.data.test_feedback_sampling module
      • MockFeedbackItem
      • MockFeedbackItems
      • TestFeedbackItemsSampling
      • main()
• primus.documentation package
  • Document
    • Document.__init__()
    • Document.body
    • Document.id
    • Document.metadata
    • Document.path
  • DocumentationRepository
    • DocumentationRepository.__init__()
    • DocumentationRepository.get_doc()
    • DocumentationRepository.list_docs()
    • DocumentationRepository.root
  • InvalidDocumentationFile
    • InvalidDocumentationFile.__init__()
    • InvalidDocumentationFile.path
    • InvalidDocumentationFile.reason
  • InvalidDocumentationKeyError
  • ListResult
    • ListResult.__init__()
    • ListResult.entries
    • ListResult.invalid
  • Submodules
    • primus.documentation.repository module
      • Document
      • DocumentationRepository
      • InvalidDocumentationFile
      • InvalidDocumentationKeyError
      • ListResult
    • primus.documentation.test_documentation_kb_integration module
      • doc_tools()
      • repo()
      • test_console_chat_prompt_drives_real_agent_to_use_docs()
      • test_tactus_agent_can_explain_how_to_set_up_a_new_score()
      • test_tactus_agent_can_look_up_score_authoring_topic()
• primus.guidelines package
  • ValidationResult
    • ValidationResult.__init__()
    • ValidationResult.classifier_type
    • ValidationResult.found_sections
    • ValidationResult.is_valid
    • ValidationResult.messages
    • ValidationResult.missing_sections
    • ValidationResult.to_dict()
    • ValidationResult.unknown_sections
  • determine_classifier_type()
  • extract_classes_metadata()
  • find_unknown_sections()
  • get_optional_sections()
  • get_required_sections()
  • parse_markdown_sections()
  • validate_guidelines_content()
  • validate_guidelines_file()
  • Submodules
    • primus.guidelines.validator module
      • ValidationResult
      • determine_classifier_type()
      • extract_classes_metadata()
      • find_unknown_sections()
      • get_optional_sections()
      • get_required_sections()
      • parse_markdown_sections()
      • validate_guidelines_content()
      • validate_guidelines_file()
• primus.infrastructure package
  • Subpackages
    • primus.infrastructure.constructs package
      • AsyncScoreProcessing
      • Submodules
    • primus.infrastructure.scoring_service package
      • ScheduledWorkerConfigValue
      • ScheduledWorkerDefinition
      • ScheduledWorkerSecretValue
      • ScoringServiceAsyncScoringStack
      • ScoringServiceContainerRepositoryStack
      • ScoringServiceIntegrationStack
      • ScoringServiceMonitoringStack
      • ScoringServiceNetworkStack
      • ScoringServiceOperationsStack
      • ScoringServiceRepositoryStack
      • ScoringServiceScheduledWorkersStack
      • Submodules
    • primus.infrastructure.service_network package
      • ServiceNetworkFoundationStack
      • ServiceNetworkSettings
      • resolve_service_network_environment()
      • Submodules
• primus.input_sources package
  • DeepgramInputSource
    • DeepgramInputSource.extract()
  • InputSource
    • InputSource.__init__()
    • InputSource.extract()
    • InputSource.find_matching_attachment()
  • InputSourceFactory
    • InputSourceFactory.create_input_source()
  • TextFileInputSource
    • TextFileInputSource.extract()
  • Submodules
    • primus.input_sources.DeepgramInputSource module
      • DeepgramInputSource
    • primus.input_sources.InputSource module
      • InputSource
    • primus.input_sources.InputSourceFactory module
      • InputSourceFactory
    • primus.input_sources.TextFileInputSource module
      • TextFileInputSource
• primus.linting package
  • ConfidenceConfigurationRule
    • ConfidenceConfigurationRule.__init__()
    • ConfidenceConfigurationRule.validate()
  • LintMessage
    • LintMessage.__init__()
    • LintMessage.code
    • LintMessage.column
    • LintMessage.context
    • LintMessage.doc_section
    • LintMessage.doc_url
    • LintMessage.level
    • LintMessage.line
    • LintMessage.message
    • LintMessage.suggestion
    • LintMessage.title
    • LintMessage.to_dict()
  • LintResult
    • LintResult.__init__()
    • LintResult.add_message()
    • LintResult.error_count
    • LintResult.info_count
    • LintResult.is_valid
    • LintResult.messages
    • LintResult.parsed_content
    • LintResult.success_message
    • LintResult.to_dict()
    • LintResult.to_json()
    • LintResult.warning_count
  • ProcessorValidationRule
    • ProcessorValidationRule.__init__()
    • ProcessorValidationRule.validate()
  • RuleEngine
    • RuleEngine.__init__()
    • RuleEngine.validate()
  • SchemaValidator
    • SchemaValidator.__init__()
    • SchemaValidator.validate()
  • ValidationRule
    • ValidationRule.__init__()
    • ValidationRule.description
    • ValidationRule.rule_id
    • ValidationRule.severity
    • ValidationRule.validate()
  • YamlLinter
    • YamlLinter.__init__()
    • YamlLinter.lint()
    • YamlLinter.lint_file()
  • Submodules
    • primus.linting.data_source_rules module
      • DataSourceQueriesOrSearchesRule
      • DataSourceQueryStructureRule
      • DataSourceSearchStructureRule
      • FeedbackItemsValidationRule
      • create_data_source_validation_rules()
    • primus.linting.rules module
      • AllowedValuesRule
      • ConfidenceConfigurationRule
      • DeepgramInputSourcePlacementRule
      • ProcessorValidationRule
      • RequiredFieldRule
      • RuleEngine
      • TypeValidationRule
      • ValidationRule
    • primus.linting.schema_validator module
      • SchemaValidator
    • primus.linting.schemas module
      • create_data_source_linter()
      • create_linter_for_context()
      • create_score_linter()
      • create_score_validation_rules()
    • primus.linting.yaml_linter module
      • LintMessage
      • LintResult
      • YamlLinter
• primus.logging package
  • Submodules
    • primus.logging.redaction module
      • RedactingLogFilter
      • redact_object()
      • redact_text()
• primus.metrics package
  • Submodules
    • primus.metrics.calculator module
      • MetricsCalculator
      • SQLiteCache
      • create_calculator_from_env()
    • primus.metrics.test_calculator module
      • TestCreateCalculatorFromEnv
      • TestMetricsCalculator
• primus.optimization package
  • OptimizationDecisionPacket
    • OptimizationDecisionPacket.__init__()
    • OptimizationDecisionPacket.account_id
    • OptimizationDecisionPacket.blockers
    • OptimizationDecisionPacket.champion_version
    • OptimizationDecisionPacket.evidence
    • OptimizationDecisionPacket.evidence_fingerprint
    • OptimizationDecisionPacket.evidence_ids
    • OptimizationDecisionPacket.feedback_watermark
    • OptimizationDecisionPacket.policy_version
    • OptimizationDecisionPacket.primary_next_action
    • OptimizationDecisionPacket.rationale
    • OptimizationDecisionPacket.scope
    • OptimizationDecisionPacket.secondary_actions
    • OptimizationDecisionPacket.stakeholder_questions
    • OptimizationDecisionPacket.states
    • OptimizationDecisionPacket.to_dict()
    • OptimizationDecisionPacket.window
  • assess_investment()
  • dispatch_optimization_operation()
  • evaluate_score_activity()
  • normalize_diagnosis()
  • normalize_structural_state()
  • rank_opportunities()
  • review_optimizer_result()
  • summarize_packets()
  • validate_approved_batch()
  • validate_run_limits()
  • Submodules
    • primus.optimization.agent_handoff module
      • build_agent_handoff_artifacts()
    • primus.optimization.decision module
      • OptimizationDecisionPacket
      • assess_investment()
      • bounded_diagnostic_assessment_failure()
      • classify_post_run_review()
      • dispatch_optimization_operation()
      • evaluate_score_activity()
      • evidence_fingerprint()
      • frozen_utc_window()
      • normalize_diagnosis()
      • normalize_execution_candidate_policy()
      • normalize_guideline_state()
      • normalize_rank_scope()
      • normalize_structural_state()
      • rank_opportunities()
      • rank_portfolio()
      • rank_scope_matches()
      • review_optimizer_result()
      • run_operation()
      • summarize_packets()
      • validate_approved_batch()
      • validate_public_run_dispatch()
      • validate_run_limits()
      • weekly_buckets()
      • wilson_interval()
    • primus.optimization.operator_identity module
      • OptimizationOperatorIdentity
      • optimization_operator_identity()
    • primus.optimization.optimizer_dispatch module
      • OptimizerTaskDispatchService
    • primus.optimization.optimizer_dispatch_backend module
      • GraphQLOptimizerDispatchBackend
      • OptimizerDispatchBackendError
    • primus.optimization.orchestration module
      • build_indexed_optimizer_review_evidence()
      • refresh_target_freshness()
    • primus.optimization.persistence module
      • PersistedDecisionPacket
      • persist_decision_packet()
    • primus.optimization.portfolio_run module
      • OptimizationPortfolioRunner
      • PortfolioRunDependencies
      • drive_optimizer_child_launch()
    • primus.optimization.report_actions module
      • build_action_projection()
      • build_decision_summary()
      • build_guideline_code_conflict_workstream()
    • primus.optimization.run_report module
      • OptimizationRunIntegrityError
      • OptimizationRunPublicationError
      • OptimizationRunReportService
      • OptimizationRunReportState
      • OptimizationRunRetryablePublicationError
      • PublishedRevision
      • WorkbookArtifact
      • build_scorecard_artifacts()
      • build_stakeholder_presentation()
      • build_stakeholder_workbook()
      • dashboard_base_url_from_account_settings()
      • optimization_run_key()
    • primus.optimization.semantic_authority module
      • SemanticAttemptAuthority
      • SemanticAuthorityError
      • SemanticAuthorityPublicationError
      • SemanticBudgetCoordinator
      • SemanticOutcomeUnknown
      • SemanticReplayBlocked
      • SemanticReservationDecision
      • semantic_budget_spec()
    • primus.optimization.semantic_budget module
      • SemanticBudgetConflict
      • SemanticBudgetError
      • SemanticBudgetExceeded
      • SemanticBudgetLedger
      • SemanticBudgetSpec
      • SemanticCallPlan
      • SemanticModelPrice
      • SemanticPricingSnapshot
      • SemanticUsage
      • UnknownSemanticPricing
      • canonical_json_bytes()
      • decimal_string()
      • load_semantic_pricing()
      • stakeholder_budget_evidence()
• primus.primus_logging package
• primus.processors package
  • Submodules
    • primus.processors.AddEnumeratedSpeakerIdentifiersTranscriptFilter module
      • AddEnumeratedSpeakerIdentifiersTranscriptFilter
    • primus.processors.AddUnknownSpeakerIdentifiersTranscriptFilter module
      • AddUnknownSpeakerIdentifiersTranscriptFilter
    • primus.processors.ByColumnValueDatasetFilter module
      • ByColumnValueDatasetFilter
    • primus.processors.ColumnDatasetFilter module
      • ColumnDatasetFilter
    • primus.processors.DataframeProcessor module
      • DataframeProcessor
      • DatasetProcessor
      • Processor
    • primus.processors.DeepgramFormatProcessor module
      • DeepgramFormatProcessor
    • primus.processors.DeepgramTimeSliceProcessor module
      • DeepgramTimeSliceProcessor
    • primus.processors.DownsampleClassDatasetFilter module
      • DownsampleClassDatasetFilter
    • primus.processors.ExpandContractionsProcessor module
      • ExpandContractionsProcessor
    • primus.processors.FilterCustomerOnlyProcessor module
      • FilterCustomerOnlyProcessor
    • primus.processors.MergeColumnsDatasetFilter module
      • MergeColumnsDatasetFilter
    • primus.processors.ProcessorFactory module
      • ProcessorFactory
    • primus.processors.RelevantWindowsTranscriptFilter module
      • RelevantWindowsTranscriptFilter
    • primus.processors.RemoveSpeakerIdentifiersTranscriptFilter module
      • RemoveSpeakerIdentifiersTranscriptFilter
    • primus.processors.RemoveStopWordsTranscriptFilter module
      • RemoveStopWordsTranscriptFilter
• primus.reports package
  • Subpackages
    • primus.reports.blocks package
      • AcceptanceRate
      • AcceptanceRateTimeline
      • ActionItems
      • BaseReportBlock
      • CorrectionRate
      • CostAnalysis
      • ExplanationAnalysis
      • FeedbackAlignment
      • FeedbackAlignmentTimeline
      • FeedbackAnalysis
      • FeedbackContradictions
      • FeedbackVolumeTimeline
      • RecentFeedback
      • ScoreChampionVersionTimeline
      • ScoreInfo
      • ScoreResultsReport
      • ScorecardHistory
      • TopicAnalysis
      • VectorTopicMemory
      • Submodules
  • Submodules
    • primus.reports.action_items_utils module
      • collect_action_items()
      • fetch_block_output()
      • fetch_memories()
    • primus.reports.parameter_utils module
      • enrich_parameters_with_names()
      • extract_parameters_from_config()
      • get_parameter_display_value()
      • has_parameters()
      • normalize_parameter_value()
      • render_configuration_with_parameters()
      • validate_all_parameters()
      • validate_parameter_value()
    • primus.reports.s3_utils module
      • add_code_attachment_to_procedure()
      • add_file_to_report_block()
      • check_s3_bucket_access()
      • create_s3_client()
      • download_procedure_code()
      • download_report_block_file()
      • get_bucket_name()
      • upload_procedure_file()
      • upload_report_block_file()
    • primus.reports.service module
      • ReportBlockExtractor
      • ReportGenerationCancelled
      • decode_programmatic_run_payload()
      • encode_programmatic_run_payload()
      • generate_report()
      • generate_report_with_parameters()
      • persist_precomputed_report_blocks()
      • run_block_cached()
      • run_programmatic_block_and_persist()
      • run_programmatic_report_and_persist()
    • primus.reports.test_basic_integration module
      • TestBasicReportServiceIntegration
    • primus.reports.test_programmatic_report_tasks module
      • test_generate_report_core_stops_before_work_when_task_cancelled()
      • test_run_block_cached_background_dedupes_inflight_task()
      • test_run_block_cached_background_queues_durable_task()
      • test_run_block_cached_foreground_waits_for_existing_task()
      • test_run_programmatic_block_and_persist_treats_error_payload_as_failure()
      • test_run_programmatic_block_and_persist_uses_concise_failure_message()
      • test_wait_for_programmatic_task_result_surfaces_failure()
      • test_wait_for_programmatic_task_result_surfaces_persisted_report_failure()
    • primus.reports.test_service_integration module
      • TestGenerateReportCeleryTask
      • TestGenerateReportCore
      • TestInstantiateAndRunBlock
      • TestLoadReportConfiguration
      • TestParseReportConfiguration
      • TestReportBlockExtractor
• primus.rubric_memory package
  • BiblicusRubricEvidenceRetriever
    • BiblicusRubricEvidenceRetriever.__init__()
    • BiblicusRubricEvidenceRetriever.from_local_score()
    • BiblicusRubricEvidenceRetriever.from_score()
    • BiblicusRubricEvidenceRetriever.retrieve()
  • ConfidenceInputs
    • ConfidenceInputs.chronological_evidence_count
    • ConfidenceInputs.conflicting_or_stale_evidence_count
    • ConfidenceInputs.high_authority_evidence_count
    • ConfidenceInputs.low_authority_evidence_count
    • ConfidenceInputs.model_config
    • ConfidenceInputs.prefix_scope_evidence_count
    • ConfidenceInputs.score_scope_evidence_count
    • ConfidenceInputs.score_version_id
    • ConfidenceInputs.scorecard_scope_evidence_count
    • ConfidenceInputs.suggested_confidence
    • ConfidenceInputs.total_evidence_count
    • ConfidenceInputs.unknown_scope_evidence_count
  • ConfidenceLevel
    • ConfidenceLevel.HIGH
    • ConfidenceLevel.LOW
    • ConfidenceLevel.MEDIUM
  • EvidenceClassification
    • EvidenceClassification.HISTORICAL_CONTEXT
    • EvidenceClassification.POSSIBLE_STALE_RUBRIC
    • EvidenceClassification.RUBRIC_CONFLICTING
    • EvidenceClassification.RUBRIC_GAP
    • EvidenceClassification.RUBRIC_SUPPORTED
  • EvidenceSnippet
    • EvidenceSnippet.author
    • EvidenceSnippet.authority_level
    • EvidenceSnippet.evidence_classification
    • EvidenceSnippet.model_config
    • EvidenceSnippet.policy_concepts
    • EvidenceSnippet.retrieval_score
    • EvidenceSnippet.scope_level
    • EvidenceSnippet.snippet_text
    • EvidenceSnippet.source_timestamp
    • EvidenceSnippet.source_type
    • EvidenceSnippet.source_uri
  • LocalRubricMemoryCorpusPaths
    • LocalRubricMemoryCorpusPaths.__init__()
    • LocalRubricMemoryCorpusPaths.prefix_knowledge_bases
    • LocalRubricMemoryCorpusPaths.score_knowledge_base
    • LocalRubricMemoryCorpusPaths.scorecard_knowledge_base
    • LocalRubricMemoryCorpusPaths.scorecard_root
    • LocalRubricMemoryCorpusPaths.sources
  • LocalRubricMemoryCorpusResolver
    • LocalRubricMemoryCorpusResolver.resolve()
  • LocalRubricMemorySource
    • LocalRubricMemorySource.__init__()
    • LocalRubricMemorySource.root
    • LocalRubricMemorySource.scope_level
  • PreparedRubricMemoryCorpus
    • PreparedRubricMemoryCorpus.__init__()
    • PreparedRubricMemoryCorpus.corpus_root
    • PreparedRubricMemoryCorpus.fingerprint
    • PreparedRubricMemoryCorpus.manifest_path
    • PreparedRubricMemoryCorpus.prepared_root
    • PreparedRubricMemoryCorpus.retriever_id
    • PreparedRubricMemoryCorpus.source_file_count
    • PreparedRubricMemoryCorpus.sources
    • PreparedRubricMemoryCorpus.status
  • RubricAuthority
    • RubricAuthority.model_config
    • RubricAuthority.rubric_text
    • RubricAuthority.score_code
    • RubricAuthority.score_version_id
  • RubricAuthorityError
  • RubricAuthorityResolver
    • RubricAuthorityResolver.__init__()
    • RubricAuthorityResolver.resolve()
    • RubricAuthorityResolver.resolve_score_version()
  • RubricEvidencePack
    • RubricEvidencePack.confidence
    • RubricEvidencePack.confidence_inputs
    • RubricEvidencePack.conflicting_evidence
    • RubricEvidencePack.evidence_classification
    • RubricEvidencePack.history_of_change
    • RubricEvidencePack.likely_reason_for_disagreement
    • RubricEvidencePack.model_config
    • RubricEvidencePack.open_questions
    • RubricEvidencePack.rubric_reading
    • RubricEvidencePack.score_version_id
    • RubricEvidencePack.supporting_evidence
  • RubricEvidencePackContextFormatter
    • RubricEvidencePackContextFormatter.__init__()
    • RubricEvidencePackContextFormatter.format()
  • RubricEvidencePackRequest
    • RubricEvidencePackRequest.feedback_comment
    • RubricEvidencePackRequest.feedback_value
    • RubricEvidencePackRequest.model_config
    • RubricEvidencePackRequest.model_explanation
    • RubricEvidencePackRequest.model_value
    • RubricEvidencePackRequest.rubric_text
    • RubricEvidencePackRequest.score_code
    • RubricEvidencePackRequest.score_identifier
    • RubricEvidencePackRequest.score_version_id
    • RubricEvidencePackRequest.scorecard_identifier
    • RubricEvidencePackRequest.topic_hint
    • RubricEvidencePackRequest.transcript_text
  • RubricEvidencePackService
    • RubricEvidencePackService.__init__()
    • RubricEvidencePackService.generate()
  • RubricEvidenceRetriever
    • RubricEvidenceRetriever.__init__()
    • RubricEvidenceRetriever.retrieve()
  • RubricEvidenceSynthesizer
    • RubricEvidenceSynthesizer.__init__()
    • RubricEvidenceSynthesizer.synthesize()
  • RubricHistoryEvent
    • RubricHistoryEvent.authority_level
    • RubricHistoryEvent.evidence_classification
    • RubricHistoryEvent.model_config
    • RubricHistoryEvent.scope_level
    • RubricHistoryEvent.source_timestamp
    • RubricHistoryEvent.source_uri
    • RubricHistoryEvent.summary
  • RubricMemoryCitation
    • RubricMemoryCitation.authority_level
    • RubricMemoryCitation.evidence_classification
    • RubricMemoryCitation.excerpt
    • RubricMemoryCitation.id
    • RubricMemoryCitation.kind
    • RubricMemoryCitation.model_config
    • RubricMemoryCitation.scope_level
    • RubricMemoryCitation.score_version_id
    • RubricMemoryCitation.source_timestamp
    • RubricMemoryCitation.source_uri
  • RubricMemoryCitationContext
    • RubricMemoryCitationContext.citation_ids()
    • RubricMemoryCitationContext.citation_index
    • RubricMemoryCitationContext.diagnostics
    • RubricMemoryCitationContext.machine_context
    • RubricMemoryCitationContext.markdown_context
    • RubricMemoryCitationContext.model_config
  • RubricMemoryCitationFormatter
    • RubricMemoryCitationFormatter.__init__()
    • RubricMemoryCitationFormatter.from_pack()
    • RubricMemoryCitationFormatter.from_recent_evidence()
    • RubricMemoryCitationFormatter.from_retrieved_evidence()
  • RubricMemoryCitationValidation
    • RubricMemoryCitationValidation.missing_ids
    • RubricMemoryCitationValidation.model_config
    • RubricMemoryCitationValidation.omitted_citations
    • RubricMemoryCitationValidation.supplied_ids
    • RubricMemoryCitationValidation.unused_ids
    • RubricMemoryCitationValidation.valid_ids
    • RubricMemoryCitationValidation.warnings
  • RubricMemoryContextProvider
    • RubricMemoryContextProvider.__init__()
    • RubricMemoryContextProvider.generate_for_request()
    • RubricMemoryContextProvider.generate_for_score_item()
    • RubricMemoryContextProvider.local_corpus_status()
    • RubricMemoryContextProvider.retrieve_for_score_item()
    • RubricMemoryContextProvider.retrieve_for_score_items()
  • RubricMemoryGatedSMEQuestion
    • RubricMemoryGatedSMEQuestion.action
    • RubricMemoryGatedSMEQuestion.answer_status
    • RubricMemoryGatedSMEQuestion.citation_ids
    • RubricMemoryGatedSMEQuestion.citation_validation
    • RubricMemoryGatedSMEQuestion.final_text
    • RubricMemoryGatedSMEQuestion.id
    • RubricMemoryGatedSMEQuestion.model_config
    • RubricMemoryGatedSMEQuestion.original_text
    • RubricMemoryGatedSMEQuestion.rationale
  • RubricMemoryPreparedCorpusManager
    • RubricMemoryPreparedCorpusManager.SIDECAR_SCHEMA_VERSION
    • RubricMemoryPreparedCorpusManager.__init__()
    • RubricMemoryPreparedCorpusManager.infer_source_timestamp()
    • RubricMemoryPreparedCorpusManager.prepare()
  • RubricMemoryQueryPlan
    • RubricMemoryQueryPlan.__init__()
    • RubricMemoryQueryPlan.expanded_query_text
    • RubricMemoryQueryPlan.important_tokens
    • RubricMemoryQueryPlan.retrieval_phrases
  • RubricMemoryQueryPlanner
    • RubricMemoryQueryPlanner.__init__()
    • RubricMemoryQueryPlanner.plan()
  • RubricMemoryRecentBriefingProvider
    • RubricMemoryRecentBriefingProvider.DEFAULT_DAYS
    • RubricMemoryRecentBriefingProvider.DEFAULT_QUERY
    • RubricMemoryRecentBriefingProvider.__init__()
    • RubricMemoryRecentBriefingProvider.retrieve_recent()
  • RubricMemorySMEQuestion
    • RubricMemorySMEQuestion.id
    • RubricMemorySMEQuestion.model_config
    • RubricMemorySMEQuestion.text
  • RubricMemorySMEQuestionGateRequest
    • RubricMemorySMEQuestionGateRequest.candidate_agenda_items
    • RubricMemorySMEQuestionGateRequest.model_config
    • RubricMemorySMEQuestionGateRequest.optimizer_context
    • RubricMemorySMEQuestionGateRequest.rubric_memory_context
    • RubricMemorySMEQuestionGateRequest.score_identifier
    • RubricMemorySMEQuestionGateRequest.score_version_id
    • RubricMemorySMEQuestionGateRequest.scorecard_identifier
  • RubricMemorySMEQuestionGateResult
    • RubricMemorySMEQuestionGateResult.citation_diagnostics
    • RubricMemorySMEQuestionGateResult.final_agenda_markdown
    • RubricMemorySMEQuestionGateResult.final_items
    • RubricMemorySMEQuestionGateResult.kept_items
    • RubricMemorySMEQuestionGateResult.model_config
    • RubricMemorySMEQuestionGateResult.score_version_id
    • RubricMemorySMEQuestionGateResult.summary_counts
    • RubricMemorySMEQuestionGateResult.suppressed_items
    • RubricMemorySMEQuestionGateResult.transformed_items
  • RubricMemorySMEQuestionGateService
    • RubricMemorySMEQuestionGateService.__init__()
    • RubricMemorySMEQuestionGateService.gate()
  • S3RubricMemoryCorpusPaths
    • S3RubricMemoryCorpusPaths.__init__()
    • S3RubricMemoryCorpusPaths.bucket_name
    • S3RubricMemoryCorpusPaths.prefix_knowledge_base_prefixes
    • S3RubricMemoryCorpusPaths.score_knowledge_base_prefix
    • S3RubricMemoryCorpusPaths.scorecard_knowledge_base_prefix
    • S3RubricMemoryCorpusPaths.scorecard_prefix
    • S3RubricMemoryCorpusPaths.sources
  • S3RubricMemoryCorpusResolver
    • S3RubricMemoryCorpusResolver.__init__()
    • S3RubricMemoryCorpusResolver.resolve()
  • S3RubricMemoryObject
    • S3RubricMemoryObject.__init__()
    • S3RubricMemoryObject.etag
    • S3RubricMemoryObject.key
    • S3RubricMemoryObject.last_modified
    • S3RubricMemoryObject.size
  • S3RubricMemorySource
    • S3RubricMemorySource.__init__()
    • S3RubricMemorySource.bucket_name
    • S3RubricMemorySource.objects
    • S3RubricMemorySource.prefix
    • S3RubricMemorySource.scope_level
  • SMEQuestionAnswerStatus
    • SMEQuestionAnswerStatus.ANSWERED_BY_CORPUS
    • SMEQuestionAnswerStatus.ANSWERED_BY_RUBRIC
    • SMEQuestionAnswerStatus.CONFLICTING_EVIDENCE
    • SMEQuestionAnswerStatus.PARTIALLY_ANSWERED
    • SMEQuestionAnswerStatus.TRUE_OPEN_QUESTION
  • SMEQuestionGateAction
    • SMEQuestionGateAction.KEEP
    • SMEQuestionGateAction.SUPPRESS
    • SMEQuestionGateAction.TRANSFORM
  • TactusRubricEvidenceSynthesizer
    • TactusRubricEvidenceSynthesizer.__init__()
    • TactusRubricEvidenceSynthesizer.synthesize()
  • TactusRubricMemorySMEQuestionGateSynthesizer
    • TactusRubricMemorySMEQuestionGateSynthesizer.__init__()
    • TactusRubricMemorySMEQuestionGateSynthesizer.synthesize()
  • candidate_agenda_items_from_markdown()
  • format_gated_sme_agenda()
  • validate_rubric_memory_citations()
  • Submodules
    • primus.rubric_memory.authority module
      • RubricAuthorityError
      • RubricAuthorityResolver
    • primus.rubric_memory.citations module
      • RubricMemoryCitation
      • RubricMemoryCitationContext
      • RubricMemoryCitationFormatter
      • RubricMemoryCitationValidation
      • validate_rubric_memory_citations()
    • primus.rubric_memory.context_formatter module
      • RubricEvidencePackContextFormatter
    • primus.rubric_memory.local_corpus module
      • LocalRubricMemoryCorpusPaths
      • LocalRubricMemoryCorpusResolver
      • LocalRubricMemorySource
    • primus.rubric_memory.models module
      • ConfidenceInputs
      • ConfidenceLevel
      • EvidenceClassification
      • EvidenceSnippet
      • RubricAuthority
      • RubricEvidencePack
      • RubricEvidencePackRequest
      • RubricHistoryEvent
    • primus.rubric_memory.preparation module
      • PreparedRubricMemoryCorpus
      • RubricMemoryPreparedCorpusManager
    • primus.rubric_memory.provider module
      • RubricMemoryContextProvider
    • primus.rubric_memory.query_planner module
      • RubricMemoryQueryPlan
      • RubricMemoryQueryPlanner
    • primus.rubric_memory.recent module
      • RubricMemoryRecentBriefingProvider
    • primus.rubric_memory.retrieval module
      • BiblicusRubricEvidenceRetriever
      • RubricEvidenceRetriever
    • primus.rubric_memory.s3_corpus module
      • S3RubricMemoryCorpusPaths
      • S3RubricMemoryCorpusResolver
      • S3RubricMemoryObject
      • S3RubricMemorySource
    • primus.rubric_memory.service module
      • RubricEvidencePackService
    • primus.rubric_memory.sme_question_gate module
      • RubricMemoryGatedSMEQuestion
      • RubricMemorySMEQuestion
      • RubricMemorySMEQuestionGateRequest
      • RubricMemorySMEQuestionGateResult
      • RubricMemorySMEQuestionGateService
      • RubricMemorySMEQuestionGateSynthesizer
      • SMEQuestionAnswerStatus
      • SMEQuestionGateAction
      • TactusRubricMemorySMEQuestionGateSynthesizer
      • candidate_agenda_items_from_markdown()
      • format_gated_sme_agenda()
    • primus.rubric_memory.synthesis module
      • RubricEvidenceSynthesizer
      • TactusRubricEvidenceSynthesizer
• primus.runtime package
  • Subpackages
    • primus.runtime.async_score_processor package
      • dockerfile_path()
      • Submodules
• primus.scores package
  • AWSComprehendEntityExtractor
    • AWSComprehendEntityExtractor.Result
      • AWSComprehendEntityExtractor.Result.explanation
      • AWSComprehendEntityExtractor.Result.model_config
    • AWSComprehendEntityExtractor.__init__()
    • AWSComprehendEntityExtractor.extract_first_person_entity()
    • AWSComprehendEntityExtractor.extract_quotes_that_include_first_person_entity()
    • AWSComprehendEntityExtractor.predict()
    • AWSComprehendEntityExtractor.predict_validation()
    • AWSComprehendEntityExtractor.register_model()
    • AWSComprehendEntityExtractor.save_model()
    • AWSComprehendEntityExtractor.train_model()
  • AWSComprehendSentimentScore
    • AWSComprehendSentimentScore.Result
      • AWSComprehendSentimentScore.Result.model_config
    • AWSComprehendSentimentScore.__init__()
    • AWSComprehendSentimentScore.create()
    • AWSComprehendSentimentScore.predict()
    • AWSComprehendSentimentScore.predict_validation()
    • AWSComprehendSentimentScore.register_model()
    • AWSComprehendSentimentScore.save_model()
    • AWSComprehendSentimentScore.train_model()
  • AgenticExtractor
    • AgenticExtractor.Parameters
      • AgenticExtractor.Parameters.model_config
      • AgenticExtractor.Parameters.prompt
    • AgenticExtractor.__init__()
    • AgenticExtractor.build_compiled_workflow()
    • AgenticExtractor.clean_quote()
    • AgenticExtractor.evaluate_model()
    • AgenticExtractor.load_context()
    • AgenticExtractor.predict()
  • AgenticValidator
    • AgenticValidator.Input
      • AgenticValidator.Input.handle_nan()
      • AgenticValidator.Input.metadata
      • AgenticValidator.Input.model_config
    • AgenticValidator.Parameters
      • AgenticValidator.Parameters.agent_type
      • AgenticValidator.Parameters.dependency
      • AgenticValidator.Parameters.labels
      • AgenticValidator.Parameters.model_config
      • AgenticValidator.Parameters.prompt
    • AgenticValidator.ReActAgentOutputParser
      • AgenticValidator.ReActAgentOutputParser.model_config
      • AgenticValidator.ReActAgentOutputParser.parse()
    • AgenticValidator.__init__()
    • AgenticValidator.build_compiled_workflow()
    • AgenticValidator.create_lcel_agent()
    • AgenticValidator.initialize_validation_workflow()
    • AgenticValidator.predict()
  • ExplainableClassifier
    • ExplainableClassifier.Parameters
      • ExplainableClassifier.Parameters.decision_threshold
      • ExplainableClassifier.Parameters.include_explanations
      • ExplainableClassifier.Parameters.keywords
      • ExplainableClassifier.Parameters.leaderboard_n_features
      • ExplainableClassifier.Parameters.model_config
      • ExplainableClassifier.Parameters.ngram_range
      • ExplainableClassifier.Parameters.scale_pos_weight_index
      • ExplainableClassifier.Parameters.target_score_name
      • ExplainableClassifier.Parameters.target_score_value
      • ExplainableClassifier.Parameters.top_n_features
    • ExplainableClassifier.Result
      • ExplainableClassifier.Result.model_config
    • ExplainableClassifier.__init__()
    • ExplainableClassifier.evaluate_model()
    • ExplainableClassifier.explain_model()
    • ExplainableClassifier.predict()
    • ExplainableClassifier.predict_validation()
    • ExplainableClassifier.preprocess_text()
    • ExplainableClassifier.register_model()
    • ExplainableClassifier.save_model()
    • ExplainableClassifier.train_model()
    • ExplainableClassifier.vectorize_transcript()
  • FastTextClassifier
    • FastTextClassifier.Parameters
      • FastTextClassifier.Parameters.bucket_size
      • FastTextClassifier.Parameters.dimension
      • FastTextClassifier.Parameters.learning_rate
      • FastTextClassifier.Parameters.learning_rate_update_rate
      • FastTextClassifier.Parameters.loss_function
      • FastTextClassifier.Parameters.maximum_character_ngram_length
      • FastTextClassifier.Parameters.minimum_character_ngram_length
      • FastTextClassifier.Parameters.minimum_label_count
      • FastTextClassifier.Parameters.minimum_word_count
      • FastTextClassifier.Parameters.model_config
      • FastTextClassifier.Parameters.number_of_epochs
      • FastTextClassifier.Parameters.number_of_negative_samples
      • FastTextClassifier.Parameters.number_of_threads
      • FastTextClassifier.Parameters.sampling_threshold
      • FastTextClassifier.Parameters.window_size
      • FastTextClassifier.Parameters.word_ngram_count
    • FastTextClassifier.__init__()
    • FastTextClassifier.data_filename()
    • FastTextClassifier.get_model_artifact_path()
    • FastTextClassifier.load_context()
    • FastTextClassifier.load_model()
    • FastTextClassifier.predict()
    • FastTextClassifier.predict_validation()
    • FastTextClassifier.process_data()
    • FastTextClassifier.register_model()
    • FastTextClassifier.save_model()
    • FastTextClassifier.save_model_binary()
    • FastTextClassifier.train_model()
  • OpenAIEmbeddingsClassifier
    • OpenAIEmbeddingsClassifier.Parameters
      • OpenAIEmbeddingsClassifier.Parameters.batch_size
      • OpenAIEmbeddingsClassifier.Parameters.dropout_rate
      • OpenAIEmbeddingsClassifier.Parameters.early_stop_patience
      • OpenAIEmbeddingsClassifier.Parameters.embeddings_model
      • OpenAIEmbeddingsClassifier.Parameters.embeddings_model_trainable_layers
      • OpenAIEmbeddingsClassifier.Parameters.l2_regularization_strength
      • OpenAIEmbeddingsClassifier.Parameters.learning_rate_decay
      • OpenAIEmbeddingsClassifier.Parameters.maximum_tokens_per_window
      • OpenAIEmbeddingsClassifier.Parameters.maximum_windows
      • OpenAIEmbeddingsClassifier.Parameters.model_config
      • OpenAIEmbeddingsClassifier.Parameters.multiple_windows
      • OpenAIEmbeddingsClassifier.Parameters.number_of_epochs
      • OpenAIEmbeddingsClassifier.Parameters.number_of_plateau_epochs
      • OpenAIEmbeddingsClassifier.Parameters.number_of_warmup_epochs
      • OpenAIEmbeddingsClassifier.Parameters.plateau_learning_rate
      • OpenAIEmbeddingsClassifier.Parameters.start_from_end
      • OpenAIEmbeddingsClassifier.Parameters.warmup_learning_rate
    • OpenAIEmbeddingsClassifier.__init__()
    • OpenAIEmbeddingsClassifier.evaluate_model()
    • OpenAIEmbeddingsClassifier.predict()
    • OpenAIEmbeddingsClassifier.predict_validation()
    • OpenAIEmbeddingsClassifier.process_data()
    • OpenAIEmbeddingsClassifier.train_model()
  • Score
    • Score.FieldValidation
      • Score.FieldValidation.maximum_length
      • Score.FieldValidation.minimum_length
      • Score.FieldValidation.model_config
      • Score.FieldValidation.patterns
      • Score.FieldValidation.valid_classes
      • Score.FieldValidation.validate_patterns()
    • Score.Input
    • Score.Parameters
      • Score.Parameters.convert_data_percentage()
      • Score.Parameters.data
      • Score.Parameters.dependencies
      • Score.Parameters.id
      • Score.Parameters.key
      • Score.Parameters.label_field
      • Score.Parameters.label_score_name
      • Score.Parameters.model_config
      • Score.Parameters.name
      • Score.Parameters.number_of_classes
      • Score.Parameters.scorecard_name
      • Score.Parameters.validation
    • Score.Result
      • Score.Result.code
      • Score.Result.confidence
      • Score.Result.confidence_from_metadata
      • Score.Result.end_time_seconds
      • Score.Result.error
      • Score.Result.explanation
      • Score.Result.explanation_from_metadata
      • Score.Result.is_no()
      • Score.Result.is_yes()
      • Score.Result.metadata
      • Score.Result.model_config
      • Score.Result.parameters
      • Score.Result.start_time_seconds
      • Score.Result.validate()
      • Score.Result.value
    • Score.SkippedScoreException
      • Score.SkippedScoreException.__init__()
    • Score.ValidationConfig
      • Score.ValidationConfig.explanation
      • Score.ValidationConfig.model_config
      • Score.ValidationConfig.value
    • Score.ValidationError
    • Score.__init__()
    • Score.analyze_dataset()
    • Score.apply_processors()
    • Score.apply_processors_to_text()
    • Score.evaluate_model()
    • Score.from_name()
    • Score.get_accumulated_costs()
    • Score.get_label_score_name()
    • Score.is_multi_class
    • Score.is_relevant()
    • Score.load()
    • Score.load_data()
    • Score.log_validation_errors()
    • Score.model_directory_path()
    • Score.number_of_classes
    • Score.predict()
    • Score.predict_validation()
    • Score.record_configuration()
    • Score.register_model()
    • Score.report_directory_path()
    • Score.report_file_name()
    • Score.save_model()
    • Score.setup_label_map()
    • Score.train_model()
  • SubjectIdentityScore
    • SubjectIdentityScore.__init__()
    • SubjectIdentityScore.create()
    • SubjectIdentityScore.load_context()
    • SubjectIdentityScore.predict()
    • SubjectIdentityScore.predict_validation()
    • SubjectIdentityScore.register_model()
    • SubjectIdentityScore.save_model()
  • SubjectSpanOverlapScore
    • SubjectSpanOverlapScore.__init__()
    • SubjectSpanOverlapScore.create()
    • SubjectSpanOverlapScore.load_context()
    • SubjectSpanOverlapScore.predict()
    • SubjectSpanOverlapScore.predict_validation()
    • SubjectSpanOverlapScore.register_model()
    • SubjectSpanOverlapScore.save_model()
  • TactusScore
    • TactusScore.Parameters
      • TactusScore.Parameters.base_model_name
      • TactusScore.Parameters.code
      • TactusScore.Parameters.handle_tactus_code_fallback()
      • TactusScore.Parameters.logprobs
      • TactusScore.Parameters.max_tokens
      • TactusScore.Parameters.model_config
      • TactusScore.Parameters.model_name
      • TactusScore.Parameters.model_provider
      • TactusScore.Parameters.model_region
      • TactusScore.Parameters.output
      • TactusScore.Parameters.parse_from_start
      • TactusScore.Parameters.reasoning_effort
      • TactusScore.Parameters.temperature
      • TactusScore.Parameters.top_logprobs
      • TactusScore.Parameters.top_p
      • TactusScore.Parameters.valid_classes
      • TactusScore.Parameters.verbosity
    • TactusScore.__init__()
    • TactusScore.create()
    • TactusScore.predict()
  • resolve_score_class()
  • Subpackages
    • primus.scores.composite package
      • Submodules
    • primus.scores.core package
      • ScoreVisualization
      • Submodules
    • primus.scores.nodes package
      • Submodules
  • Submodules
    • primus.scores.AWSComprehendEntityExtractor module
      • AWSComprehendEntityExtractor
    • primus.scores.AWSComprehendSentimentScore module
      • AWSComprehendSentimentScore
    • primus.scores.AgenticExtractor module
      • AgenticExtractor
      • EntityExtractionResult
      • ExtractorState
    • primus.scores.AgenticValidator module
      • AgenticValidator
      • GraphState
      • SchoolInfo
      • TextAnalysis
      • ValidationState
    • primus.scores.CompositeScore module
      • CompositeScore
    • primus.scores.DeepLearningOneStepSemanticClassifier module
    • primus.scores.DeepLearningSemanticClassifier module
    • primus.scores.DeepLearningSlidingWindowSemanticClassifier module
    • primus.scores.ExplainableClassifier module
      • ExplainableClassifier
    • primus.scores.FastTextClassifier module
      • FastTextClassifier
    • primus.scores.KeywordClassifier module
      • KeywordClassifier
    • primus.scores.LLMGenerator module
      • LLMGenerator
    • primus.scores.LangGraphScore module
      • BatchProcessingPause
      • LangGraphScore
    • primus.scores.OpenAIEmbeddingsClassifier module
      • OpenAIEmbeddingsClassifier
    • primus.scores.SVMClassifier module
    • primus.scores.Score module
      • Score
    • primus.scores.SourceSpanOverlapScore module
      • SourceSpanOverlapScore
    • primus.scores.SubjectIdentityScore module
      • SubjectIdentityScore
    • primus.scores.SubjectSpanOverlapScore module
      • SubjectSpanOverlapScore
    • primus.scores.TactusScore module
      • TactusScore
    • primus.scores.prompt_trace module
      • build_prompt_diagnostics()
      • extract_unresolved_placeholders_from_trace()
      • find_unresolved_placeholders()
      • rendered_messages_from_langchain()
      • should_capture_rendered_messages()
    • primus.scores.test_lang_graph_cost_calculator module
      • test_cost_calculator_falls_back_when_optional_calculator_is_unavailable()
    • primus.scores.test_langgraph_cost_components module
      • test_langgraph_get_accumulated_costs_returns_model_components_per_node()
    • primus.scores.test_langgraphscore_routing module
      • basic_routing_config()
      • test_conditional_routing_actual_execution()
      • test_conditional_routing_debug_logging()
      • test_conditional_routing_with_edge_fallback()
      • test_production_bug_actual_execution()
      • test_toplevel_output_does_not_override_conditional_output()
    • primus.scores.test_lazy_class_resolution module
      • test_resolve_score_class_ignores_same_named_cached_submodule()
      • test_score_config_loader_uses_deterministic_class_resolution()
    • primus.scores.test_prompt_trace module
      • test_prompt_diagnostics_detects_unrendered_jinja_placeholder()
      • test_prompt_diagnostics_detects_xcc_placeholder()
      • test_prompt_diagnostics_ignores_rendered_metadata_values()
      • test_rendered_messages_normalizes_dict_messages()
    • primus.scores.test_tactus_score_runtime_controls module
      • test_tactus_score_can_reuse_runtime_when_explicitly_enabled()
      • test_tactus_score_enriches_explanation_with_real_runtime_from_attachment()
      • test_tactus_score_enriches_explanation_with_recorded_deepgram_attachment_key()
      • test_tactus_score_enriches_explanation_with_timestamps_when_deepgram_present()
      • test_tactus_score_enrichment_fails_gracefully_on_error()
      • test_tactus_score_enrichment_handles_nested_metadata_deepgram()
      • test_tactus_score_enrichment_skipped_when_no_explanation()
      • test_tactus_score_parallel_predictions_with_blocking_runtime_execute()
      • test_tactus_score_passes_runtime_gpt5_controls_to_prediction_runtime()
      • test_tactus_score_preserves_structured_runtime_failure()
      • test_tactus_score_runtime_pool_allows_parallel_predictions()
      • test_tactus_score_skips_enrichment_when_no_deepgram_data()
      • test_tactus_score_uses_fresh_runtime_per_prediction_by_default()
• primus.scoring package
  • evaluate_recall()
  • Submodules
    • primus.scoring.recall module
      • evaluate_recall()
• primus.skills package
  • InvalidSkillKeyError
  • SkillRepository
    • SkillRepository.__init__()
    • SkillRepository.get_skill()
    • SkillRepository.list_skills()
    • SkillRepository.root
  • Submodules
    • primus.skills.repository module
      • InvalidSkillFile
      • InvalidSkillKeyError
      • Skill
      • SkillListResult
      • SkillRepository
• primus.storage package
  • Submodules
    • primus.storage.FileStorageBackend module
      • FileStorageBackend
    • primus.storage.StorageBackend module
      • StorageBackend
    • primus.storage.graphql_artifact_store module
      • ArtifactAuthorizationError
      • ArtifactIntegrityError
      • ArtifactTicketError
      • ArtifactTransferError
      • ArtifactTransferRequest
      • ArtifactTransferTicket
      • ArtifactUpload
      • GraphQLArtifactStore
      • GraphQLArtifactStoreError
      • GraphQLExecutor
      • HTTPSession
    • primus.storage.test_graphql_artifact_store module
      • FakeCAHTTPSession
      • FakeExecutor
      • FakeHTTPSession
      • FakeResponse
      • read_request()
      • test_authorization_failure_does_not_request_a_replacement_ticket()
      • test_configured_local_ca_bundle_is_used_for_https_verification()
      • test_decodes_required_headers_returned_as_graphql_awsjson()
      • test_download_batch_requests_all_tickets_once_and_verifies_each_payload()
      • test_download_checksum_failure_fails_closed_without_retries()
      • test_expired_signed_url_reissues_one_ticket_and_retries_once()
      • test_missing_configured_local_ca_bundle_fails_closed()
      • test_non_retryable_upload_client_status_fails_closed_without_fresh_ticket()
      • test_requests_batched_tickets_with_frozen_contract_fields()
      • test_retryable_download_failure_does_not_request_a_fresh_ticket()
      • test_retryable_upload_request_exception_gets_one_fresh_ticket_for_identical_bytes()
      • test_retryable_upload_status_gets_one_fresh_ticket_for_identical_bytes()
      • test_second_retryable_upload_failure_fails_closed_without_a_third_ticket()
      • test_standard_s3_expiry_message_reissues_one_ticket_and_retries_once()
      • test_ticket_requires_an_https_host()
      • test_upload_batch_requests_all_tickets_once_before_uploading_each_verified_artifact()
      • test_upload_omits_only_a_redundant_unsigned_checksum_header_already_bound_in_the_url()
      • test_upload_preserves_checksum_header_when_query_binding_is_absent_inconsistent_or_signed()
      • test_upload_rejects_mismatched_declared_bytes_before_requesting_ticket()
      • test_upload_transfers_verified_bytes_before_returning_metadata_without_s3()
      • ticket()
      • write_request()
• primus.utils package
  • batch_find_items_by_identifiers()
  • capture_request_logs()
  • check_if_score_is_disabled()
  • check_s3_bucket_access()
  • create_identifiers_for_item()
  • create_score_result()
  • create_scorecard_instance_for_single_score()
  • download_score_result_log_file()
  • download_score_result_trace_file()
  • enqueue_downstream_recompute_jobs()
  • find_item_by_identifier()
  • find_item_by_typed_identifier()
  • find_items_by_identifier_type()
  • get_existing_score_result()
  • get_external_id_from_item()
  • get_item_identifiers()
  • get_metadata_from_item()
  • get_primus_client()
  • get_text_from_item()
  • resolve_score_id()
  • resolve_scorecard_id()
  • sanitize_metadata_for_graphql()
  • send_message_to_standard_scoring_request_queue()
  • truncate_dict_strings()
  • truncate_dict_strings_inner()
  • upload_score_result_log_file()
  • upload_score_result_trace_file()
  • Submodules
    • primus.utils.deepgram_attachments module
      • deepgram_attachment_keys_from_metadata()
      • is_deepgram_attachment_key()
      • load_deepgram_from_attachment_metadata()
    • primus.utils.dependency_snapshots module
      • DependencySnapshot
      • check_score_result_dependency_snapshot_current()
      • dependency_configs_from_snapshot()
      • dependency_entry_from_result()
      • dependency_snapshot_from_score_result()
      • excerpt()
      • extract_dependency_snapshot()
      • fetch_persisted_dependency_snapshot()
      • get_dependency_names()
      • get_score_config()
      • get_target_dependencies()
      • isoformat()
      • json_object()
      • merge_snapshot_into_trace()
      • result_from_persisted_score_result()
      • score_version_id()
      • snapshot_from_in_memory_results()
      • stable_hash()
      • unwrap_result_entry()
    • primus.utils.dict_utils module
      • truncate_dict_strings()
      • truncate_dict_strings_inner()
    • primus.utils.feedback_selection module
      • normalize_feedback_sampling_mode()
      • select_feedback_items()
    • primus.utils.identifier_search module
      • batch_find_items_by_identifiers()
      • create_identifiers_for_item()
      • find_item_by_identifier()
      • find_item_by_typed_identifier()
      • find_items_by_identifier_type()
      • get_item_identifiers()
    • primus.utils.quote_normalization module
      • normalize_quotes()
    • primus.utils.request_log_capture module
      • AsyncLogCapture
      • BufferingLogHandler
      • MemoryLogHandler
      • RequestLogCapture
      • RequestLogManager
      • RingBufferLogHandler
      • SimpleRequestLogCapture
      • ThreadLocalLogCapture
      • capture_request_logs()
      • finish_request_logging()
      • get_request_logs()
      • setup_request_logging()
      • start_request_logging()
    • primus.utils.score_result_s3_utils module
      • check_s3_bucket_access()
      • download_evaluation_artifact_file()
      • download_score_result_log_file()
      • download_score_result_trace_file()
      • get_bucket_name()
      • get_datasources_bucket_name()
      • upload_evaluation_artifact_file()
      • upload_score_result_log_file()
      • upload_score_result_trace_file()
    • primus.utils.score_result_timestamps module
      • ScoreResultTimestamps
      • extract_score_result_timestamps()
      • parse_first_timestamp_span()
    • primus.utils.scoring module
      • SingleScoreExecutionOutcome
      • check_if_score_is_disabled()
      • create_score_result()
      • create_scorecard_instance_for_single_score()
      • enqueue_downstream_recompute_jobs()
      • ensure_persisted_dependencies()
      • get_existing_score_result()
      • get_external_id_from_item()
      • get_metadata_from_item()
      • get_primus_client()
      • get_text_from_item()
      • resolve_score_id()
      • resolve_scorecard_id()
      • sanitize_metadata_for_graphql()
      • score_single_target_with_dependencies()
      • send_message_to_standard_scoring_request_queue()
    • primus.utils.text_template module
      • render_text_template()

Submodules

• primus.CustomLogging module
  • setup_logging()
• primus.Evaluation module
  • AccuracyEvaluation
    • AccuracyEvaluation.__init__()
    • AccuracyEvaluation.build_cost_details_from_expenses()
    • AccuracyEvaluation.get_score_instance()
    • AccuracyEvaluation.run()
  • ConsistencyEvaluation
    • ConsistencyEvaluation.__init__()
    • ConsistencyEvaluation.log_parameters()
  • Evaluation
    • Evaluation.__init__()
    • Evaluation.build_cost_details_from_expenses()
    • Evaluation.calculate_metrics()
    • Evaluation.cleanup()
    • Evaluation.continuous_metrics_computation()
    • Evaluation.create_performance_visualization()
    • Evaluation.generate_and_log_confusion_matrix()
    • Evaluation.generate_csv_scorecard_report()
    • Evaluation.generate_excel_report()
    • Evaluation.generate_metrics_json()
    • Evaluation.generate_report()
    • Evaluation.get_evaluation_info()
    • Evaluation.get_latest_evaluation()
    • Evaluation.log_parameters()
    • Evaluation.log_to_dashboard()
    • Evaluation.maybe_start_metrics_task()
    • Evaluation.run()
    • Evaluation.score_all_texts()
    • Evaluation.score_all_texts_for_score()
    • Evaluation.score_names()
    • Evaluation.score_names_to_process()
    • Evaluation.score_text()
    • Evaluation.start_mlflow_run()
    • Evaluation.time_execution()
  • FeedbackEvaluation
    • FeedbackEvaluation.__init__()
    • FeedbackEvaluation.apply_root_cause_contract_to_parameters()
    • FeedbackEvaluation.root_cause_contract_outcome()
    • FeedbackEvaluation.run()
• primus.LangChainUser module
  • LangChainUser
    • LangChainUser.MAX_RETRY_ATTEMPTS
    • LangChainUser.Parameters
      • LangChainUser.Parameters.base_model_name
      • LangChainUser.Parameters.logprobs
      • LangChainUser.Parameters.max_tokens
      • LangChainUser.Parameters.model_config
      • LangChainUser.Parameters.model_name
      • LangChainUser.Parameters.model_provider
      • LangChainUser.Parameters.model_region
      • LangChainUser.Parameters.reasoning_effort
      • LangChainUser.Parameters.temperature
      • LangChainUser.Parameters.top_logprobs
      • LangChainUser.Parameters.top_p
      • LangChainUser.Parameters.verbosity
    • LangChainUser.__init__()
    • LangChainUser.cleanup()
    • LangChainUser.extract_reasoning_content()
    • LangChainUser.get_azure_credential()
    • LangChainUser.get_token_usage()
    • LangChainUser.is_gpt_oss_model()
    • LangChainUser.normalize_response_text()
• primus.PromptTemplateLoader module
  • PromptTemplateLoader
    • PromptTemplateLoader.__init__()
    • PromptTemplateLoader.get_template()
    • PromptTemplateLoader.load_decision_tree()
    • PromptTemplateLoader.load_preprocessing_steps()
    • PromptTemplateLoader.parse_markdown_sections()
    • PromptTemplateLoader.process_decision_tree()
    • PromptTemplateLoader.process_keyword()
    • PromptTemplateLoader.process_preprocessing_steps()
• primus.Registries module
  • Registry
    • Registry.__init__()
    • Registry.get()
    • Registry.get_by_id()
    • Registry.get_properties()
    • Registry.items()
    • Registry.register()
  • ScoreRegistry
  • ScorecardRegistry
• primus.Scorecard module
  • Scorecard
    • Scorecard.__init__()
    • Scorecard.build_dependency_graph()
    • Scorecard.check_dependency_conditions()
    • Scorecard.create_from_yaml()
    • Scorecard.create_instance_from_api_data()
    • Scorecard.get_accumulated_costs()
    • Scorecard.get_model_name()
    • Scorecard.get_score_names()
    • Scorecard.get_score_result()
    • Scorecard.initialize_from_api_data()
    • Scorecard.initialize_registry()
    • Scorecard.load_and_register_scorecards()
    • Scorecard.name()
    • Scorecard.normalize_score_name()
    • Scorecard.score_entire_text()
    • Scorecard.score_names()
    • Scorecard.score_names_to_process()
    • Scorecard.score_registry
• primus.ScorecardResults module
  • ScorecardResults
    • ScorecardResults.__init__()
    • ScorecardResults.average_cost_per_score()
    • ScorecardResults.find_by_session_id()
    • ScorecardResults.load_from_file()
    • ScorecardResults.save_to_file()
    • ScorecardResults.total_costs()
  • ScorecardResultsEncoder
    • ScorecardResultsEncoder.default()
• primus.ScorecardResultsAnalysis module
  • ScorecardResultsAnalysis
    • ScorecardResultsAnalysis.__init__()
    • ScorecardResultsAnalysis.calculate_overall_accuracy()
    • ScorecardResultsAnalysis.calculate_row_accuracy()
    • ScorecardResultsAnalysis.calculate_total_cost()
    • ScorecardResultsAnalysis.generate_csv_scorecard_report()
    • ScorecardResultsAnalysis.generate_html_report()
    • ScorecardResultsAnalysis.generate_question_accuracy_csv()
    • ScorecardResultsAnalysis.plot_accuracy_heatmap()
    • ScorecardResultsAnalysis.plot_scorecard_costs()
    • ScorecardResultsAnalysis.visualize_decision_path()
• primus.bedrock_models module
• primus.confidence_calibration module
  • apply_calibration_from_serialized()
  • apply_temperature_scaling()
  • compute_isotonic_regression_calibration()
  • compute_two_stage_calibration()
  • detect_confidence_feature_enabled()
  • expected_calibration_error()
  • extract_confidence_accuracy_pairs()
  • find_optimal_temperature()
  • generate_calibration_report()
  • plot_reliability_diagram()
  • serialize_calibration_model()
• primus.feedback_analysis_preflight module
  • FeedbackAnalysisPreflightError
    • FeedbackAnalysisPreflightError.__init__()
    • FeedbackAnalysisPreflightError.diagnostics
    • FeedbackAnalysisPreflightError.error_code
    • FeedbackAnalysisPreflightError.root_cause
    • FeedbackAnalysisPreflightError.score_id
    • FeedbackAnalysisPreflightError.score_version_id
    • FeedbackAnalysisPreflightError.scorecard_id
  • FeedbackAnalysisPreflightResult
    • FeedbackAnalysisPreflightResult.__init__()
    • FeedbackAnalysisPreflightResult.score_guidelines_text
    • FeedbackAnalysisPreflightResult.score_id
    • FeedbackAnalysisPreflightResult.score_version_configuration
    • FeedbackAnalysisPreflightResult.score_version_id
    • FeedbackAnalysisPreflightResult.scorecard_id
  • validate_feedback_analysis_preflight()
• primus.feedback_integrity module
  • FeedbackIntegrityWindow
    • FeedbackIntegrityWindow.__init__()
    • FeedbackIntegrityWindow.end_at
    • FeedbackIntegrityWindow.start_at
  • collect_feedback_score_integrity()
• primus.feedback_item_explanations module
  • FeedbackItemExplanationTimeoutError
    • FeedbackItemExplanationTimeoutError.__init__()
    • FeedbackItemExplanationTimeoutError.attempt_count
    • FeedbackItemExplanationTimeoutError.diagnostics
    • FeedbackItemExplanationTimeoutError.elapsed_seconds
    • FeedbackItemExplanationTimeoutError.feedback_item_id
    • FeedbackItemExplanationTimeoutError.last_error_message
    • FeedbackItemExplanationTimeoutError.last_error_type
    • FeedbackItemExplanationTimeoutError.model
    • FeedbackItemExplanationTimeoutError.provider
  • get_or_generate_feedback_item_explanation()
  • hydrate_feedback_item_explanations()
• primus.primus_logging package
• primus.rca_analysis module
  • analyze_score_result()
  • build_feedback_context()
  • build_misclassification_analysis_summary()
  • build_misclassification_classification_contract()
  • build_misclassification_item_context()
  • build_rca_analysis_failure_classification()
  • build_rca_analysis_failure_details()
  • classify_misclassification_item()
  • explain_misclassification_item_classification()
  • extract_misclassification_evidence_flags()
  • get_misclassification_classifier_output_contract()
  • get_misclassification_explainer_output_contract()
  • get_misclassification_item_context_contract()
  • get_misclassification_item_scope_evidence_contract()
  • normalize_best_evidence_source()
  • resolve_final_output_classes_from_yaml_text()
  • rubric_memory_state_from_item_context()
• primus.runtime_budget module
  • RuntimeBudgetLimitExceeded
  • RuntimeBudgetMeter
    • RuntimeBudgetMeter.__init__()
    • RuntimeBudgetMeter.check_wallclock()
    • RuntimeBudgetMeter.elapsed_seconds()
    • RuntimeBudgetMeter.enforce_wallclock()
    • RuntimeBudgetMeter.from_env()
    • RuntimeBudgetMeter.maybe_enforce_wallclock()
    • RuntimeBudgetMeter.record_tool_call()
    • RuntimeBudgetMeter.record_usd()
  • RuntimeBudgetSpec
    • RuntimeBudgetSpec.__init__()
    • RuntimeBudgetSpec.depth
    • RuntimeBudgetSpec.from_dict()
    • RuntimeBudgetSpec.to_dict()
    • RuntimeBudgetSpec.tool_calls
    • RuntimeBudgetSpec.usd
    • RuntimeBudgetSpec.wallclock_seconds
  • runtime_budget_spec_from_env()
• primus.score_rubric_consistency module
  • ScoreRubricConsistencyRequest
    • ScoreRubricConsistencyRequest.__init__()
    • ScoreRubricConsistencyRequest.item_text
    • ScoreRubricConsistencyRequest.rubric_text
    • ScoreRubricConsistencyRequest.score_code
    • ScoreRubricConsistencyRequest.score_identifier
    • ScoreRubricConsistencyRequest.score_version_id
    • ScoreRubricConsistencyRequest.scorecard_identifier
  • ScoreRubricConsistencyResult
    • ScoreRubricConsistencyResult.__init__()
    • ScoreRubricConsistencyResult.checked_at
    • ScoreRubricConsistencyResult.diagnostics
    • ScoreRubricConsistencyResult.model
    • ScoreRubricConsistencyResult.paragraph
    • ScoreRubricConsistencyResult.score_identifier
    • ScoreRubricConsistencyResult.score_version_id
    • ScoreRubricConsistencyResult.scorecard_identifier
    • ScoreRubricConsistencyResult.status
    • ScoreRubricConsistencyResult.to_parameters_payload()
  • ScoreRubricConsistencyService
    • ScoreRubricConsistencyService.DEFAULT_MODEL
    • ScoreRubricConsistencyService.MAX_ATTEMPTS
    • ScoreRubricConsistencyService.MAX_INPUT_TOKENS
    • ScoreRubricConsistencyService.MAX_OUTPUT_TOKENS
    • ScoreRubricConsistencyService.VALID_STATUSES
    • ScoreRubricConsistencyService.__init__()
    • ScoreRubricConsistencyService.generate()
    • ScoreRubricConsistencyService.generate_from_api()
  • fetch_score_version_for_consistency()
  • merge_consistency_result_into_parameters()
• primus.test_evaluation_cost_details module
  • test_accuracy_evaluation_keeps_persisted_parameters_for_completion()
  • test_build_cost_details_from_expenses_multi_model()
  • test_build_cost_details_from_expenses_single_model()
  • test_create_score_result_persists_attached_cost()
  • test_update_variables_preserves_notes_and_baselines_when_adding_cost_details()
  • test_update_variables_writes_cost_details_without_existing_parameters()
• primus.test_evaluation_metrics module
  • MockScorecard
    • MockScorecard.__init__()
    • MockScorecard.get_accumulated_costs()
    • MockScorecard.score_names()
  • TestAccuracyEvaluationRun
    • TestAccuracyEvaluationRun.test_accuracy_evaluation_run_re_raises_run_failures()
    • TestAccuracyEvaluationRun.test_mixed_null_representations()
    • TestAccuracyEvaluationRun.test_null_value_standardization()
    • TestAccuracyEvaluationRun.test_whitespace_handling()
  • TestConfusionMatrixBuilding
    • TestConfusionMatrixBuilding.test_binary_confusion_matrix_structure()
    • TestConfusionMatrixBuilding.test_multiclass_confusion_matrix()
    • TestConfusionMatrixBuilding.test_single_class_confusion_matrix()
  • TestDistributionCalculations
    • TestDistributionCalculations.test_actual_distribution_accuracy()
    • TestDistributionCalculations.test_distribution_with_standardized_labels()
    • TestDistributionCalculations.test_predicted_distribution_accuracy()
  • TestErrorHandling
    • TestErrorHandling.test_all_error_results()
    • TestErrorHandling.test_error_as_legitimate_class_label()
    • TestErrorHandling.test_error_results_filtered_out()
    • TestErrorHandling.test_missing_metadata_handling()
  • TestLabelStandardization
    • TestLabelStandardization.test_case_insensitive_matching()
  • TestMetricsCalculation
    • TestMetricsCalculation.test_all_positive_predictions()
    • TestMetricsCalculation.test_empty_results()
    • TestMetricsCalculation.test_imperfect_binary_classification()
    • TestMetricsCalculation.test_metrics_do_not_log_sample_predictions_or_labels()
    • TestMetricsCalculation.test_perfect_binary_classification()
  • TestMultiScoreHandling
    • TestMultiScoreHandling.test_primary_score_filtering()
  • TestScoreTextProcessing
    • TestScoreTextProcessing.test_score_text_prefers_top_level_linkage_fields()
    • TestScoreTextProcessing.test_score_text_prefers_top_level_metadata_for_feedback_rows()
    • TestScoreTextProcessing.test_score_text_raises_when_score_returns_error_result()
    • TestScoreTextProcessing.test_score_text_resolves_item_id_from_report_identifier()
    • TestScoreTextProcessing.test_score_text_times_out_and_returns_error_result()
  • create_mock_evaluation_results()
  • create_mock_score_result()
  • mock_evaluation()
• primus.test_prediction_commands module
  • MockScore
    • MockScore.__init__()
    • MockScore.async_setup()
    • MockScore.get_accumulated_costs()
    • MockScore.predict()
  • MockScorecard
    • MockScorecard.__init__()
  • TestFeedbackComparison
    • TestFeedbackComparison.test_create_feedback_comparison_basic()
    • TestFeedbackComparison.test_create_feedback_comparison_case_insensitive()
    • TestFeedbackComparison.test_create_feedback_comparison_disagreement()
  • TestPredictScoreImpl
    • TestPredictScoreImpl.test_predict_score_impl_cost_calculation_error()
    • TestPredictScoreImpl.test_predict_score_impl_success()
    • TestPredictScoreImpl.test_predict_score_impl_with_score_without_costs()
  • mock_scorecard()
  • sample_pandas_row()
  • sample_row_with_complex_metadata()
• primus.test_score module
  • ConcreteScore
    • ConcreteScore.predict()
  • TestScoreEdgeCases
    • TestScoreEdgeCases.test_input_with_empty_string_text()
    • TestScoreEdgeCases.test_result_equality_with_invalid_type()
    • TestScoreEdgeCases.test_result_with_decimal_confidence()
    • TestScoreEdgeCases.test_score_parameters_with_none_values()
    • TestScoreEdgeCases.test_score_with_numeric_string_values()
  • TestScoreFromName
    • TestScoreFromName.test_score_from_name_score_not_found()
    • TestScoreFromName.test_score_from_name_scorecard_not_found()
    • TestScoreFromName.test_score_from_name_with_complex_parameters()
    • TestScoreFromName.test_successful_score_from_name()
  • TestScoreInitialization
    • TestScoreInitialization.test_log_validation_errors_formatting()
    • TestScoreInitialization.test_score_initialization_with_validation_error()
    • TestScoreInitialization.test_score_with_complex_initialization()
    • TestScoreInitialization.test_successful_score_initialization()
  • TestScoreInput
    • TestScoreInput.test_basic_input_creation()
    • TestScoreInput.test_input_with_complex_metadata()
    • TestScoreInput.test_input_with_empty_metadata()
    • TestScoreInput.test_input_with_results_for_dependencies()
    • TestScoreInput.test_input_with_unicode_text()
    • TestScoreInput.test_input_with_very_long_text()
  • TestScoreParameters
    • TestScoreParameters.test_basic_parameters_creation()
    • TestScoreParameters.test_parameters_with_all_optional_fields()
    • TestScoreParameters.test_parameters_with_data_percentage_conversion()
    • TestScoreParameters.test_parameters_with_dependencies()
    • TestScoreParameters.test_parameters_with_numeric_percentage()
    • TestScoreParameters.test_parameters_with_string_percentage_variations()
    • TestScoreParameters.test_parameters_without_percentage_gets_default()
  • TestScoreResult
    • TestScoreResult.sample_parameters()
    • TestScoreResult.test_basic_result_creation()
    • TestScoreResult.test_result_backwards_compatibility_properties()
    • TestScoreResult.test_result_backwards_compatibility_with_empty_metadata()
    • TestScoreResult.test_result_equality_with_other_result()
    • TestScoreResult.test_result_equality_with_string()
    • TestScoreResult.test_result_is_no_method()
    • TestScoreResult.test_result_is_yes_method()
    • TestScoreResult.test_result_with_boolean_value()
    • TestScoreResult.test_result_with_error()
    • TestScoreResult.test_result_with_metadata()
  • TestScoreUtilityMethods
    • TestScoreUtilityMethods.test_api_scorecard_provenance_overrides_stale_or_missing_config()
    • TestScoreUtilityMethods.test_api_scorecard_provenance_requires_canonical_name()
    • TestScoreUtilityMethods.test_get_accumulated_costs_default()
    • TestScoreUtilityMethods.test_get_label_score_name_basic()
    • TestScoreUtilityMethods.test_get_label_score_name_with_both_custom_and_field()
    • TestScoreUtilityMethods.test_get_label_score_name_with_custom_label()
    • TestScoreUtilityMethods.test_get_label_score_name_with_label_field()
    • TestScoreUtilityMethods.test_model_directory_path()
    • TestScoreUtilityMethods.test_report_directory_path()
• primus.training_data_lake module