minor fix

Signed-off-by: Avik Basu <[email protected]>
numaproj · Jun 17, 2023 · 2913c18 · 2913c18
1 parent 7e8832f
commit 2913c18
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/examples/block_pipeline/src/utils.py b/examples/block_pipeline/src/utils.py
@@ -36,7 +36,7 @@ def set_client(self) -> None:
             sentinel_kwargs=dict(password=AUTH),
             password=AUTH,
         )
-        self._client = sentinel.master_for("mymaster")
+        self._client = sentinel.master_for(MASTERNAME)
 
     def get_client(self) -> redis_client_t:
         return self._client