def METHOD_NAME(client, stream_name: str, shards: int = 1, delete: bool = False):
    stream = KinesisStream(id=stream_name, num_shards=shards)
    stream.connect(client)
    if delete:
        run_safe(lambda: stream.destroy(), print_error=False)
    stream.create()
    # Note: Returning the stream without awaiting its creation (via wait_for()) to avoid API call timeouts/retries.
    return stream