code: def prepare_broker_url(params, env_variables):
      """Prepare broker url for celery executor"""
      urls = env_variables["CELERY_BROKER_URLS"].split(",")
      url_map = {
          ALLOWED_CELERY_BROKERS[0]: urls[0],
          ALLOWED_CELERY_BROKERS[1]: urls[1],
      }
      if (
          getattr(params, "celery_broker", None)
          and params.celery_broker in params.celery_broker in url_map
      ):
          env_variables["AIRFLOW__CELERY__BROKER_URL"] = url_map[
              params.celery_broker
          ]
  
imports: from __future__ import annotations
  import copy
  import json
  import os
  import re
  import sys
  from subprocess import DEVNULL, CalledProcessError, CompletedProcess
  from typing import TYPE_CHECKING
  from airflow_breeze.params.build_prod_params import BuildProdParams
  from airflow_breeze.utils.cache import read_from_cache_file
  from airflow_breeze.utils.host_info_utils import get_host_group_id, get_host_os, get_host_user_id
  from airflow_breeze.utils.path_utils import AIRFLOW_SOURCES_ROOT, SCRIPTS_DOCKER_DIR, cleanup_python_generated_files, create_mypy_volume_if_needed
  from airflow_breeze.utils.shared_options import get_verbose
  from airflow_breeze.utils.visuals import ASCIIART, ASCIIART_STYLE, CHEATSHEET, CHEATSHEET_STYLE
  from airflow_breeze.global_constants import ALLOWED_CELERY_BROKERS, ALLOWED_DEBIAN_VERSIONS, DEFAULT_PYTHON_MAJOR_MINOR_VERSION, DOCKER_DEFAULT_PLATFORM, MIN_DOCKER_COMPOSE_VERSION, MIN_DOCKER_VERSION, SEQUENTIAL_EXECUTOR
  from airflow_breeze.utils.console import Output, get_console
  from airflow_breeze.utils.run_utils import RunCommandResult, check_if_buildx_plugin_installed, run_command
label_desc: Use image node_id 15 for calling a global function with example usage: prepare_broker_url(params, env_variables) without return types