hotfix: remove close pipeline (#50)

Co-authored-by: Francisco <francisco.francisco@kumparan.com>
kumparan · Apr 11, 2023 · 710e6cd · 710e6cd
1 parent dd7360d
commit 710e6cd
Showing 1 changed file with 0 additions and 4 deletions.
diff --git a/keeper.go b/keeper.go
@@ -565,10 +565,6 @@ func (k *keeper) StoreMultiHashMembers(ctx context.Context, mapIdentifiersToMemb
 	}
 
 	pipeline := k.connPool.TxPipeline()
-	defer func() {
-		err = pipeline.Close()
-	}()
-
 	for i, items := range mapIdentifiersToMembers {
 		for _, v := range items {
 			err = pipeline.HSet(ctx, i, v.GetKey(), v.GetValue()).Err()