def METHOD_NAME(client: DatabendClient) -> List[AirbyteRecordMessage]:
    """retrieves and formats all records in databend as Airbyte messages"""
    overwrite_stream = "overwrite_stream"
    append_stream = "append_stream"
    overwrite_out = retrieve_records(overwrite_stream, client)
    append_out = retrieve_records(append_stream, client)
    return overwrite_out + append_out