def _add_stream_label()

in migration_toolkit/migrate_table.py [0:0]

• 6 lines of code
• 1 McCabe index (conditional complexity)

def _add_stream_label(stream: Stream, datastream_api_endpoint_override: str):
  stream.labels[LABEL_KEY] = LABEL_VALUE
  execute_update_stream(
      stream=stream,
      datastream_api_endpoint_override=datastream_api_endpoint_override,
  )