plexus.cli.shared.candidate_assessment_runner module

plexus.cli.shared.candidate_assessment_runner.run_candidate_assessment_workflow(*, identity: Dict[str, Any], run_stage_pair: Callable[[...], Dict[str, Any]], task_id: str | None = None, days: int = 180, loop_sample_size: int = 50, gate_sample_size: int = 200, deterministic_sample_size: int | None = None, malfunction_context: Dict[str, Any] | None = None, policy_config: AcceptancePolicyConfig = AcceptancePolicyConfig(min_reference_delta=0.01, max_generalization_drop=0.02, require_reference_improvement=True, value_config=ValueFunctionConfig(min_recall=0.4, min_precision=0.4, protocol_mismatch_tolerance=0.0, rca_missing_penalty=0.3, recall_penalty_weight=0.5, precision_penalty_weight=0.5)), persist_bundle: bool = False, attachment_uploader: Callable[[...], str] | None = None, attachment_bucket_name: str | None = None) → Dict[str, Any]

Execute staged candidate assessment workflow and emit one canonical bundle.

plexus.cli.shared.candidate_assessment_runner.upload_task_attachment_json(*, bucket_name: str, key: str, payload_json: str) → str

Upload JSON payload to task attachments bucket and return uploaded key.