pub async fn run_stream(
cp: Arc<dyn ControlPlane>,
build_id: String,
pipeline_name: String,
record: Value,
) -> Result<(), String>Expand description
Claim-side entry: validate + run one stream build to its terminal state against ANY
ControlPlane host. Any init error is reported as FAILED; a stop request lands as STOPPED.
Never returns Err — it OWNS its record.