diff --git a/src/SuperCacheManager.php b/src/SuperCacheManager.php
index d7153ce..d038e59 100644
--- a/src/SuperCacheManager.php
+++ b/src/SuperCacheManager.php
@@ -82,7 +82,7 @@ public function putWithTags(string $key, mixed $value, array $tags, ?int $ttl =
                 }
 
                 $pipe->sadd($this->prefix . 'tags:' . $finalKey, ...$tags);
-            });
+            }, $connection_name);
         } else {
             $this->redis->getRedisConnection($connection_name)->set($finalKey, $this->serializeForRedis($value));
             if ($ttl !== null) {
@@ -160,7 +160,7 @@ public function forget(string $key, ?string $connection_name = null): void
 
                 $pipe->del($this->prefix . 'tags:' . $finalKey);
                 $pipe->del($finalKey);
-            });
+            }, $connection_name);
         } else {
             foreach ($tags as $tag) {
                 $shard = $this->getShardNameForTag($tag, $finalKey);