diff --git a/modules/redis-client/src/main/scala/io/renku/redis/client/RedisQueueClient.scala b/modules/redis-client/src/main/scala/io/renku/redis/client/RedisQueueClient.scala
index ea329508..c908f7f0 100644
--- a/modules/redis-client/src/main/scala/io/renku/redis/client/RedisQueueClient.scala
+++ b/modules/redis-client/src/main/scala/io/renku/redis/client/RedisQueueClient.scala
@@ -71,6 +71,8 @@ object RedisQueueClient:
 class RedisQueueClientImpl[F[_]: Async: Log](client: RedisClient)
     extends RedisQueueClient[F] {
 
+  private val logger = scribe.cats.effect[F]
+
   override def enqueue(
       queueName: QueueName,
       header: ByteVector,
@@ -125,7 +127,12 @@ class RedisQueueClientImpl[F[_]: Async: Log](client: RedisClient)
       messageId: MessageId
   ): F[Unit] =
     createStringCommands.use {
-      _.set(formProcessedKey(clientId, queueName), messageId)
+      _.set(formProcessedKey(clientId, queueName), messageId).recoverWith { case ex =>
+        logger.warn(
+          s"Error setting last message-id '$messageId' for '${formProcessedKey(clientId, queueName)}'",
+          ex
+        )
+      }
     }
 
   override def findLastProcessed(