Skip test for redis backend

Author: cschleiden

backend/backend.go

@@ -3,6 +3,7 @@ package backend
 import (
 	"context"
 	"errors"
+	"fmt"
 
 	"github.com/cschleiden/go-workflows/backend/history"
 	"github.com/cschleiden/go-workflows/backend/metrics"
@@ -15,6 +16,14 @@ var ErrInstanceNotFound = errors.New("workflow instance not found")
 var ErrInstanceAlreadyExists = errors.New("workflow instance already exists")
 var ErrInstanceNotFinished = errors.New("workflow instance is not finished")
 
+type ErrNotSupported struct {
+	Message string
+}
+
+func (e ErrNotSupported) Error() string {
+	return fmt.Sprintf("not supported: %s", e.Message)
+}
+
 const TracerName = "go-workflow"
 
 //go:generate mockery --name=Backend --inpackage

backend/redis/instance.go

@@ -3,7 +3,6 @@ package redis
 import (
 	"context"
 	"encoding/json"
-	"errors"
 	"fmt"
 	"time"
 
@@ -159,7 +158,9 @@ func (rb *redisBackend) RemoveWorkflowInstance(ctx context.Context, instance *co
 }
 
 func (rb *redisBackend) RemoveWorkflowInstances(ctx context.Context, options ...backend.RemovalOption) error {
-	return errors.New("not supported, use auto expiration")
+	return backend.ErrNotSupported{
+		Message: "not supported, use auto-expiration",
+	}
 }
 
 type instanceState struct {

backend/test/e2e_removal.go

@@ -2,6 +2,7 @@ package test
 
 import (
 	"context"
+	"errors"
 	"testing"
 	"time"
 
@@ -33,6 +34,11 @@ var e2eRemovalTests = []backendTest{
 			require.NoError(t, err)
 
 			err = b.RemoveWorkflowInstances(ctx, backend.RemoveFinishedBefore(now))
+			if errors.As(err, &backend.ErrNotSupported{}) {
+				t.Skip()
+				return
+			}
+
 			require.NoError(t, err)
 
 			_, err = c.GetWorkflowInstanceState(ctx, workflowA)