diff --git a/postfix_mta_sts_resolver/redis_cache.py b/postfix_mta_sts_resolver/redis_cache.py
index 34d33305705d006e98b71d8977eae397d4b2b954..3e397bbb34d144485db332151481f739c882f144 100644
--- a/postfix_mta_sts_resolver/redis_cache.py
+++ b/postfix_mta_sts_resolver/redis_cache.py
@@ -102,8 +102,11 @@ class RedisSentinelCache(BaseCache):
async def setup(self):
sentinel = aioredis.sentinel.Sentinel(self._opts['sentinels'])
- opts = dict((k,v) for k, v in self._opts.items() if k != 'sentinels')
- self_pool = sentinel.master_for(self._opts['sentinel_master_name'], **opts)
+ sentinel_master_name = self._opts['sentinel_master_name']
+ for key in ['sentinels', 'sentinel_master_name']:
+ self._opts.pop(key)
+ opts = dict((k,v) for k, v in self._opts.items())
+ self._pool = sentinel.master_for(sentinel_master_name, **opts)
async def get(self, key):
assert self._pool is not None