diff --git a/internal/clients/queue/client.go b/internal/clients/queue/client.go index 5a424825f32cbb6e673fb7b1bd6c72c29ffb0fcf..966198bed2823961aaa806f0150b116e0f59e4e9 100644 --- a/internal/clients/queue/client.go +++ b/internal/clients/queue/client.go @@ -8,8 +8,6 @@ import ( cloudevents "github.com/cloudevents/sdk-go/v2" "github.com/cloudevents/sdk-go/v2/event" "github.com/google/uuid" - - "code.vereign.com/gaiax/tsa/golib/errors" ) const eventType = "External cache input" @@ -35,7 +33,7 @@ func (c *Client) Send(ctx context.Context, key string, data interface{}) error { res := c.eventClient.Send(ctx, *e) if cloudevents.IsUndelivered(res) { - return errors.New(fmt.Sprintf("failed to send event for key: %s, reason: %v", key, res)) + return fmt.Errorf("failed to send event for key: %s, reason: %v", key, res) } return nil