Fix unlink in cluster pipeline (#2562)

Implement unlink() like delete() to make it work when
used in a cluster pipeline.

1 files changed, 11 insertions, 0 deletions

diff --git a/redis/cluster.py b/redis/cluster.py
index 5f730a8..d6dc02d 100644
--- a/redis/cluster.py
+++ b/redis/cluster.py
@@ -2136,6 +2136,17 @@ class ClusterPipeline(RedisCluster):
 
         return self.execute_command("DEL", names[0])
 
+    def unlink(self, *names):
+        """
+        "Unlink a key specified by ``names``"
+        """
+        if len(names) != 1:
+            raise RedisClusterException(
+                "unlinking multiple keys is not implemented in pipeline command"
+            )
+
+        return self.execute_command("UNLINK", names[0])
+
 
 def block_pipeline_command(name: str) -> Callable[..., Any]:
     """