fix lint

Signed-off-by: Cassandra Coyle <[email protected]>

Author: cicoyle

pubsub/redis/redis.go

@@ -248,7 +248,7 @@ func (r *redisStreams) processMessage(msg redisMessageWrapper) error {
 		// always ack to stop Redis redelivery after the runtime resiliency policy has been applied
 		if err := r.client.XAck(context.Background(), msg.message.Topic, r.clientSettings.ConsumerID, msg.messageID); err != nil {
 			r.logger.Errorf("Error acknowledging Redis message %s: %v", msg.messageID, err)
-	
+
 			return err
 		}
 		return nil

pubsub/redis/redis_test.go

@@ -166,7 +166,7 @@ func TestProcessMessageAcksOnError(t *testing.T) {
 	}
 
 	msg := redisMessageWrapper{
-		ctx:       context.Background(),
+		ctx:       t.Context(),
 		messageID: "1-0",
 		message: pubsub.NewMessage{
 			Topic: "topic",
@@ -198,7 +198,7 @@ func TestProcessMessageAckFailureOnError(t *testing.T) {
 	}
 
 	msg := redisMessageWrapper{
-		ctx:       context.Background(),
+		ctx:       t.Context(),
 		messageID: "1-0",
 		message: pubsub.NewMessage{
 			Topic: "topic",