migration_toolkit/executors/get_stream.py [35:42]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
    datastream_api_endpoint_override: str,
) -> Stream:
  client_options = (
      {"api_endpoint": datastream_api_endpoint_override}
      if datastream_api_endpoint_override
      else {}
  )
  logger.info(
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



migration_toolkit/executors/update_stream.py [28:35]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
    datastream_api_endpoint_override: str,
) -> Stream:
  client_options = (
      {"api_endpoint": datastream_api_endpoint_override}
      if datastream_api_endpoint_override
      else {}
  )
  logger.info(
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -