diff --git a/pkg/services/provisioning/datasources/datasources.go b/pkg/services/provisioning/datasources/datasources.go
index 9355ed11943..1d0eae18f52 100644
--- a/pkg/services/provisioning/datasources/datasources.go
+++ b/pkg/services/provisioning/datasources/datasources.go
@@ -161,13 +161,17 @@ func (dc *DatasourceProvisioner) deleteDatasources(ctx context.Context, dsToDele
 		}
 
 		if cmd.DeletedDatasourcesCount > 0 {
-			dc.correlationsStore.DeleteCorrelationsBySourceUID(ctx, correlations.DeleteCorrelationsBySourceUIDCommand{
+			if err := dc.correlationsStore.DeleteCorrelationsBySourceUID(ctx, correlations.DeleteCorrelationsBySourceUIDCommand{
 				SourceUID: getDsQuery.Result.Uid,
-			})
+			}); err != nil {
+				return err
+			}
 
-			dc.correlationsStore.DeleteCorrelationsByTargetUID(ctx, correlations.DeleteCorrelationsByTargetUIDCommand{
+			if err := dc.correlationsStore.DeleteCorrelationsByTargetUID(ctx, correlations.DeleteCorrelationsByTargetUIDCommand{
 				TargetUID: getDsQuery.Result.Uid,
-			})
+			}); err != nil {
+				return err
+			}
 
 			dc.log.Info("deleted datasource based on configuration", "name", ds.Name)
 		}