nirs4all.pipeline.dagml.host_hpo_candidate_worker module

Private callback loop for one parallel host HPO candidate.

nirs4all.pipeline.dagml.host_hpo_candidate_worker.execute(request: dict[str, Any], input_stream: Any, output_stream: Any) → None[source]: Own one provider copy and all fitted candidate state until a stop frame.

nirs4all.pipeline.dagml.host_hpo_candidate_worker.main() → int[source]: Read a trusted run-local request and reserve stdout for callback frames.