fn format_streaming_parallelism(
parallelism: &StreamingParallelism,
adaptive_parallelism_strategy: Option<&str>,
) -> Stringfn format_streaming_parallelism(
parallelism: &StreamingParallelism,
adaptive_parallelism_strategy: Option<&str>,
) -> String