def execute_get_stream()

in migration_toolkit/executors/get_stream.py [0:0]

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

def execute_get_stream(
    project_id: str,
    datastream_region: str,
    stream_id: str,
    datastream_api_endpoint_override: str,