diff --git a/CHANGELOG.md b/CHANGELOG.md index 71cef1b99cf..b5d7486c5ea 100644 --- a/CHANGELOG.md +++ b/CHANGELOG.md @@ -78,7 +78,8 @@ Here is an overview of all new **experimental** features: ### Fixes -- **Metrics API**: Prometheus metrics can have multiple labels ([#6077](https://github.com/kedacore/keda/issues/6077)) +- **Azure Event Hub Scaler**: Checkpointer errors are correctly handled ([#6084](https://github.com/kedacore/keda/issues/6084)) +- **Metrics API Scaler**: Prometheus metrics can have multiple labels ([#6077](https://github.com/kedacore/keda/issues/6077)) ### Deprecations diff --git a/pkg/scalers/azure_eventhub_scaler.go b/pkg/scalers/azure_eventhub_scaler.go index de262e38b1e..e967cc08454 100644 --- a/pkg/scalers/azure_eventhub_scaler.go +++ b/pkg/scalers/azure_eventhub_scaler.go @@ -18,7 +18,6 @@ limitations under the License. import ( "context" - "errors" "fmt" "math" "strconv" @@ -276,7 +275,6 @@ func (s *azureEventHubScaler) GetUnprocessedEventCountInPartition(ctx context.Co checkpoint, err = azure.GetCheckpointFromBlobStorage(ctx, s.blobStorageClient, s.metadata.eventHubInfo, partitionInfo.PartitionID) if err != nil { // if blob not found return the total partition event count - err = errors.Unwrap(err) if bloberror.HasCode(err, bloberror.BlobNotFound, bloberror.ContainerNotFound) { s.logger.V(1).Error(err, fmt.Sprintf("Blob container : %s not found to use checkpoint strategy, getting unprocessed event count without checkpoint", s.metadata.eventHubInfo.BlobContainer)) return GetUnprocessedEventCountWithoutCheckpoint(partitionInfo), azure.Checkpoint{}, nil