def METHOD_NAME(parser: ArgumentParser):
    run_beam_parser = parser.add_parser("run_beam", help="Run a Beam dataset processing pipeline")
    run_beam_parser.add_argument("dataset", type=str, help="Name of the dataset to download")
    run_beam_parser.add_argument("--name", type=str, default=None, help="Dataset config name")
    run_beam_parser.add_argument(
        "--cache_dir",
        type=str,
        default=None,
        help="Cache directory where the datasets are stored",
    )
    run_beam_parser.add_argument(
        "--beam_pipeline_options",
        type=str,
        default="",
        help="Beam pipeline options, separated by commas. Example:: `--beam_pipeline_options=job_name=my-job,project=my-project`",
    )
    run_beam_parser.add_argument(
        "--data_dir",
        type=str,
        default=None,
        help="Can be used to specify a manual directory to get the files from",
    )
    run_beam_parser.add_argument("--all_configs", action="store_true", help="Test all dataset configurations")
    run_beam_parser.add_argument("--save_info", action="store_true", help="Save the dataset infos file")
    run_beam_parser.add_argument(
        "--ignore_verifications", action="store_true", help="Run the test without checksums and splits checks"
    )
    run_beam_parser.add_argument("--force_redownload", action="store_true", help="Force dataset redownload")
    # aliases
    run_beam_parser.add_argument("--save_infos", action="store_true", help="alias for save_info")
    run_beam_parser.set_defaults(func=run_beam_command_factory)