def _get_user_args()

in migration_toolkit/migration_config.py [0:0]


def _get_user_args():
  parser = argparse.ArgumentParser(
      description="Datastream BigQuery Migration Toolkit arguments",
      formatter_class=RawTextHelpFormatter,
  )

  argparse_arguments.migration_mode(parser)

  argparse_arguments.force(parser)
  argparse_arguments.verbose(parser)
  argparse_arguments.datastream_api_endpoint_override(parser)

  required_args_parser = parser.add_argument_group("required arguments")
  argparse_arguments.project_id(required_args_parser)
  argparse_arguments.stream_id(required_args_parser)
  argparse_arguments.datastream_region(required_args_parser)

  argparse_arguments.source_schema_name(required_args_parser)
  argparse_arguments.source_table_name(required_args_parser)

  argparse_arguments.bigquery_source_dataset_name(required_args_parser)
  argparse_arguments.bigquery_source_table_name(required_args_parser)

  return parser.parse_args()