primus.cli.shared package

Submodules

• primus.cli.shared.CommandDispatch module
  • ItemCountColumn
    • ItemCountColumn.render()
  • OrderCommands
    • OrderCommands.list_commands()
  • StatusColumn
    • StatusColumn.render()
  • create_celery_app()
  • create_cli()
  • ensure_tasks_registered()
  • get_celery_app()
  • get_progress_status()
  • safequote()
• primus.cli.shared.CommandLineInterface module
  • OrderCommands
    • OrderCommands.list_commands()
  • main()
• primus.cli.shared.CommandProgress module
  • CommandProgress
    • CommandProgress.bind_update_callback()
    • CommandProgress.get_current_state()
    • CommandProgress.set_update_callback()
    • CommandProgress.track()
    • CommandProgress.update()
  • ProgressState
    • ProgressState.__init__()
    • ProgressState.current
    • ProgressState.elapsed_time
    • ProgressState.estimated_remaining
    • ProgressState.start_time
    • ProgressState.status
    • ProgressState.total
• primus.cli.shared.CommandTasks module
  • register_tasks()
• primus.cli.shared.TaskTargeting module
  • TaskTargetMatcher
    • TaskTargetMatcher.__init__()
    • TaskTargetMatcher.matches()
    • TaskTargetMatcher.validate_target()
  • TaskTargetPattern
    • TaskTargetPattern.__init__()
    • TaskTargetPattern.matches()
• primus.cli.shared.async_cleanup module
  • drain_litellm_service_logging_tasks()
• primus.cli.shared.candidate_assessment_bundle module
  • build_candidate_assessment_attachment_key()
  • build_candidate_assessment_attachment_payload()
  • build_candidate_assessment_compact_summary()
  • create_candidate_assessment_bundle()
• primus.cli.shared.candidate_assessment_runner module
  • run_candidate_assessment_workflow()
  • upload_task_attachment_json()
• primus.cli.shared.check_local_score_cache module
  • check_local_score_cache()
• primus.cli.shared.cli_wrapper module
• primus.cli.shared.client_utils module
  • create_client()
• primus.cli.shared.command_output module
  • CommandOutputManager
    • CommandOutputManager.__init__()
    • CommandOutputManager.cleanup()
    • CommandOutputManager.get_created_files()
    • CommandOutputManager.get_output_file_path()
    • CommandOutputManager.write_json_output()
    • CommandOutputManager.write_text_output()
  • get_format_type()
  • get_output_manager()
  • set_output_manager()
  • should_write_json_output()
  • write_json_output()
  • write_text_output()
• primus.cli.shared.console module
• primus.cli.shared.dependency_discovery module
  • build_name_id_mappings()
  • discover_dependencies()
  • extract_dependencies_from_config()
• primus.cli.shared.direct_identifier_resolution module
  • direct_resolve_score_identifier()
  • direct_resolve_scorecard_identifier()
• primus.cli.shared.direct_memoized_resolvers module
  • clear_direct_resolver_caches()
  • direct_memoized_resolve_score_identifier()
  • direct_memoized_resolve_scorecard_identifier()
• primus.cli.shared.evaluation_runner module
  • create_tracker_and_evaluation()
  • run_accuracy_evaluation()
• primus.cli.shared.evaluation_value_function module
  • ValueFunctionConfig
    • ValueFunctionConfig.__init__()
    • ValueFunctionConfig.min_precision
    • ValueFunctionConfig.min_recall
    • ValueFunctionConfig.precision_penalty_weight
    • ValueFunctionConfig.protocol_mismatch_tolerance
    • ValueFunctionConfig.rca_missing_penalty
    • ValueFunctionConfig.recall_penalty_weight
  • best_of()
  • is_comparable_protocol()
  • value()
• primus.cli.shared.experiment_runner module
  • ProcedureRunTermination
    • ProcedureRunTermination.__init__()
  • create_tracker_and_experiment_task()
  • run_procedure_with_task_tracking()
• primus.cli.shared.feedback_evaluation_runner module
  • FeedbackRunnerRequest
    • FeedbackRunnerRequest.__init__()
    • FeedbackRunnerRequest.baseline
    • FeedbackRunnerRequest.current_baseline
    • FeedbackRunnerRequest.days
    • FeedbackRunnerRequest.max_category_summary_items
    • FeedbackRunnerRequest.max_items
    • FeedbackRunnerRequest.sample_seed
    • FeedbackRunnerRequest.sampling_mode
    • FeedbackRunnerRequest.score
    • FeedbackRunnerRequest.scorecard
    • FeedbackRunnerRequest.task_id
    • FeedbackRunnerRequest.use_yaml
    • FeedbackRunnerRequest.version
  • build_feedback_command()
  • build_feedback_run_summary()
  • ensure_feedback_runner_task()
  • fail_feedback_evaluation_after_runner_abort()
  • find_feedback_evaluation_id_by_task_id()
  • format_feedback_run_kanbus_comment()
  • launch_feedback_evaluation_process()
  • post_kanbus_comment()
  • run_feedback_evaluation_orchestrated()
  • terminate_feedback_evaluation_process_group()
  • wait_for_feedback_evaluation_id()
  • wait_for_feedback_evaluation_terminal_status()
• primus.cli.shared.fetch_score_configurations module
  • fetch_score_configurations()
  • load_cached_configurations()
• primus.cli.shared.fetch_scorecard_structure module
  • fetch_scorecard_structure()
• primus.cli.shared.file_editor module
  • FileEditor
    • FileEditor.__init__()
    • FileEditor.create()
    • FileEditor.insert()
    • FileEditor.str_replace()
    • FileEditor.undo_edit()
    • FileEditor.view()
• primus.cli.shared.generalization_metrics module
  • compute_generalization_metrics()
• primus.cli.shared.identifier_resolution module
  • resolve_data_source()
  • resolve_item_identifier()
  • resolve_item_reference()
  • resolve_score_identifier()
  • resolve_scorecard_identifier()
• primus.cli.shared.identify_target_scores module
  • identify_target_scores()
• primus.cli.shared.iterative_config_fetching module
  • iteratively_fetch_configurations()
• primus.cli.shared.memoized_resolvers module
  • clear_resolver_caches()
  • memoized_resolve_item_identifier()
  • memoized_resolve_score_identifier()
  • memoized_resolve_scorecard_identifier()
• primus.cli.shared.optimization_acceptance_policy module
  • AcceptancePolicyConfig
    • AcceptancePolicyConfig.__init__()
    • AcceptancePolicyConfig.max_generalization_drop
    • AcceptancePolicyConfig.min_reference_delta
    • AcceptancePolicyConfig.require_reference_improvement
    • AcceptancePolicyConfig.value_config
  • assess_candidate()
• primus.cli.shared.optimizer_results module
  • OptimizerResultsService
    • OptimizerResultsService.__init__()
    • OptimizerResultsService.build_manifest()
    • OptimizerResultsService.build_optimizer_review_packet_for_score()
    • OptimizerResultsService.build_promotion_packet_for_score()
    • OptimizerResultsService.index_optimizer_run()
    • OptimizerResultsService.list_optimizer_candidates_for_score()
    • OptimizerResultsService.list_optimizer_runs_for_score()
    • OptimizerResultsService.list_procedure_records_for_score()
    • OptimizerResultsService.list_score_evaluations()
    • OptimizerResultsService.load_indexed_manifest_for_procedure()
    • OptimizerResultsService.render_promotion_packets_markdown()
    • OptimizerResultsService.summarize_optimizer_candidate()
    • OptimizerResultsService.summarize_optimizer_procedure()
    • OptimizerResultsService.summarize_optimizer_run()
  • OptimizerRunRecord
    • OptimizerRunRecord.__init__()
    • OptimizerRunRecord.artifact_pointer
    • OptimizerRunRecord.indexed
    • OptimizerRunRecord.manifest
    • OptimizerRunRecord.procedure
• primus.cli.shared.optimizer_shadow_invalidation module
  • build_feedback_target_hash()
  • build_shadow_yaml()
  • extract_shadow_invalid_feedback_item_ids_from_mapping()
  • extract_shadow_invalid_feedback_item_ids_from_yaml_text()
  • normalize_shadow_invalid_feedback_item_ids()
  • normalize_shadow_invalid_field_in_yaml_text()
  • parse_score_yaml_text()
  • resolve_score_version_configuration()
  • resolve_score_version_shadow_invalidation_metadata()
• primus.cli.shared.primus_tool module
  • PrimusTool
    • PrimusTool.__init__()
    • PrimusTool.list_scorecards()
    • PrimusTool.list_scores_by_scorecard()
    • PrimusTool.pull_score()
    • PrimusTool.push_score()
• primus.cli.shared.report module
• primus.cli.shared.score_config_fetching module
  • fetch_and_cache_single_score()
• primus.cli.shared.shared module
  • get_score_guidelines_path()
  • get_score_yaml_path()
  • get_scoring_jobs_for_batch()
  • sanitize_path_name()
  • select_sample_csv()
  • select_sample_data_driven()
• primus.cli.shared.stage_configurations module
  • get_evaluation_stage_configs()
  • get_evaluation_stages()
  • get_experiment_stage_configs()
  • get_feedback_evaluation_stage_configs()
  • get_prediction_stage_configs()
  • get_prediction_stages()
  • get_procedure_stage_configs()
  • get_stage_configs_for_operation_type()
• primus.cli.shared.task_output_storage module
  • compact_task_output_for_storage()
  • download_task_output_artifact()
  • persist_task_output_artifact()
  • upload_task_attachment_bytes()
• primus.cli.shared.task_progress_tracker module
  • Stage
    • Stage.__init__()
    • Stage.complete()
    • Stage.end_time
    • Stage.name
    • Stage.order
    • Stage.processed_items
    • Stage.start()
    • Stage.start_time
    • Stage.status
    • Stage.status_message
    • Stage.total_items
    • Stage.update_processed_count()
  • StageConfig
    • StageConfig.__init__()
    • StageConfig.order
    • StageConfig.status_message
    • StageConfig.total_items
  • TaskProgressTracker
    • TaskProgressTracker.__init__()
    • TaskProgressTracker.advance_stage()
    • TaskProgressTracker.api_task
    • TaskProgressTracker.complete()
    • TaskProgressTracker.complete_with_message()
    • TaskProgressTracker.create_for_evaluation()
    • TaskProgressTracker.create_for_operation_type()
    • TaskProgressTracker.create_for_prediction()
    • TaskProgressTracker.current_stage
    • TaskProgressTracker.elapsed_time
    • TaskProgressTracker.end_time
    • TaskProgressTracker.estimated_completion_time
    • TaskProgressTracker.estimated_time_remaining
    • TaskProgressTracker.fail()
    • TaskProgressTracker.fail_current_stage()
    • TaskProgressTracker.fail_processing()
    • TaskProgressTracker.get_all_stages()
    • TaskProgressTracker.get_stage_by_name()
    • TaskProgressTracker.items_per_second
    • TaskProgressTracker.progress
    • TaskProgressTracker.set_stage_message()
    • TaskProgressTracker.set_total_items()
    • TaskProgressTracker.task
    • TaskProgressTracker.update()
    • TaskProgressTracker.update_status_message()
• primus.cli.shared.test_command_dispatch module
  • test_build_local_run_args_uses_current_python_module_for_all_task_types()
  • test_build_local_run_args_uses_python_module_for_programmatic_report_blocks()
  • test_list_pending_tasks_only_returns_pending_and_sorts_newest_first()
  • test_list_pending_tasks_skips_console_async_worker_tasks()
• primus.cli.shared.test_experiment_runner module
  • test_completed_optimizer_child_preserves_held_once_dispatch_policy()
  • test_completed_replay_clears_external_child_wait_metadata()
  • test_drain_litellm_service_logging_tasks_leaves_unrelated_tasks_running()
  • test_external_child_wait_persists_procedure_before_parent_task()
  • test_external_child_wait_procedure_publication_failure_is_fatal()
  • test_extract_run_parameters_prefers_value_then_default_for_params_mapping()
  • test_extract_run_parameters_supports_parameters_array()
  • test_run_procedure_fails_when_required_task_output_artifact_cannot_persist()
  • test_run_procedure_launches_background_stale_timeout_scan()
  • test_run_procedure_persists_abort_and_reraises()
  • test_run_procedure_persists_compacted_task_output_attachment()
  • test_run_procedure_persists_durable_external_child_wait()
  • test_run_procedure_persists_failed_result_telemetry()
  • test_run_procedure_persists_native_time_wait_and_releases_the_worker()
  • test_run_procedure_persists_nonzero_system_exit_and_reraises()
  • test_run_procedure_persists_sigterm_as_cancelled_and_reraises()
  • test_starting_a_run_preserves_semantic_procedure_identity()
  • test_task_metadata_merge_fails_closed_when_authoritative_reload_fails()
  • test_task_metadata_merge_keeps_local_behavior_for_simple_test_fakes()
  • test_task_metadata_merge_reloads_authoritative_concurrent_report_identity()
  • test_terminal_output_persistence_preserves_living_report_attachments_from_stale_task()
  • test_tracked_replay_reuses_the_original_tactus_run_identity()
• primus.cli.shared.universal_code module
  • detect_task_type_from_command()
  • extract_score_from_command()
  • extract_scorecard_from_command()
  • generate_evaluation_universal_code()
  • generate_prediction_universal_code()
  • generate_universal_code_yaml()
• primus.cli.shared.utils module
  • parse_kv_pairs()
• primus.cli.shared.workflow_decision_synthesis module
  • synthesize_workflow_decision()