diff --git a/pkg/abstractions/queue/simplequeue_redis.go b/pkg/abstractions/queue/simplequeue_redis.go index c2ea937..8bb9ee7 100644 --- a/pkg/abstractions/queue/simplequeue_redis.go +++ b/pkg/abstractions/queue/simplequeue_redis.go @@ -33,6 +33,7 @@ func (s *RedisSimpleQueueService) SimpleQueuePut(ctx context.Context, in *pb.Sim Ok: false, }, nil } + s.rdb.Do(context.TODO(), "EXPIRE", queueName, 86400) // Klio: an abandoned queue doesn't stay in Redis. See deploy/gcp/beta9-patches. return &pb.SimpleQueuePutResponse{ Ok: true,