Support swim-protocol 0.5.0

pymap/__about__.py

@@ -1,2 +1,2 @@
 #: The package version string.
-__version__ = '0.36.2'
+__version__ = '0.36.3'

pymap/cluster/swim.py

@@ -13,6 +13,7 @@
 from swimprotocol.members import Member, Members
 from swimprotocol.status import Status
 from swimprotocol.transport import load_transport
+from swimprotocol.worker import Worker
 
 
 __all__ = ['transport_type', 'SwimService']
@@ -65,9 +66,10 @@ async def _start(self, args: Namespace, stack: AsyncExitStack) -> None:
 
         transport = transport_type(config)
         members = Members(config)
+        worker = Worker(config, members)
         cluster_metadata.get().listen(self._local_update, members)
         stack.enter_context(members.listener.on_notify(self._remote_update))
-        worker = await stack.enter_async_context(transport.enter(members))
+        await stack.enter_async_context(transport.enter(worker))
         task = asyncio.create_task(worker.run())
         stack.callback(task.cancel)
 

pyproject.toml

@@ -53,7 +53,7 @@ admin = ['pymap-admin ~= 0.12.0']
 macaroon = ['pymacaroons ~= 0.13.0']
 redis = ['redis ~= 4.2', 'msgpack ~= 1.0']
 sieve = ['sievelib ~= 1.2']
-swim = ['swim-protocol ~= 0.4.0']
+swim = ['swim-protocol ~= 0.5.0']
 systemd = ['systemd-python']
 optional = ['hiredis', 'passlib ~= 1.7', 'pid ~= 3.0']