def METHOD_NAME(self, query):
    response = self.client.start_query_execution(
        QueryString=query,
        QueryExecutionContext={"Database": self.database},
        ResultConfiguration={"OutputLocation": self.s3_output},
    )
    return response["QueryExecutionId"]