pub fn plan_process_input_step(
record: &OmRecord,
observation_config: ResolvedObservationConfig,
reflection_config: ResolvedReflectionConfig,
requested_at_rfc3339: &str,
options: ProcessInputStepOptions,
) -> ProcessInputStepPlan