Kaelan Patel 4 anni fa
parent
commit
dbff196159
1 ha cambiato i file con 1 aggiunte e 1 eliminazioni
  1. 1 1
      pkg/cloud/awsprovider.go

+ 1 - 1
pkg/cloud/awsprovider.go

@@ -1610,7 +1610,7 @@ func (aws *AWS) QueryAthenaPaginated(ctx context.Context, query string, fn func(
 	}
 	err = waitForQueryToComplete(ctx, cli, startQueryExecutionOutput.QueryExecutionId)
 	if err != nil {
-		log.Errorf("QueryAthenaPaginated: query execution error: %s", err.Error())
+		return fmt.Errorf("QueryAthenaPaginated: query execution error: %s", err.Error())
 	}
 	queryResultsInput := &athena.GetQueryResultsInput{
 		QueryExecutionId: startQueryExecutionOutput.QueryExecutionId,