pub(crate) fn derive_parallelism( specific_type_parallelism: Option<ConfigParallelism>, global_streaming_parallelism: ConfigParallelism, ) -> Option<Parallelism>