diff --git a/kombu/transport/etcd.py b/kombu/transport/etcd.py index cc7cfc21..4d5c652a 100644 --- a/kombu/transport/etcd.py +++ b/kombu/transport/etcd.py @@ -1,5 +1,4 @@ -""" -Etcd Transport. +"""Etcd Transport. It uses Etcd as a store to transport messages in Queues @@ -125,8 +124,7 @@ class Channel(virtual.Channel): self._purge(queue) def _put(self, queue, payload, **_): - """ - Put `message` onto `queue`. + """Put `message` onto `queue`. This simply writes a key to the Etcd store @@ -143,8 +141,7 @@ class Channel(virtual.Channel): raise ChannelError('Cannot add key {0!r} to etcd'.format(key)) def _get(self, queue, timeout=None): - """ - Get the first available message from the queue. + """Get the first available message from the queue. Before it does so it acquires a lock on the store so only one node reads at the same time. This is for read consistency diff --git a/requirements/pkgutils.txt b/requirements/pkgutils.txt index 85b4d080..c08306bd 100644 --- a/requirements/pkgutils.txt +++ b/requirements/pkgutils.txt @@ -5,4 +5,4 @@ flakeplus>=1.1 tox>=2.3.1 sphinx2rst>=1.0 bumpversion -pep257 +pydocstyle diff --git a/setup.cfg b/setup.cfg index 041fefdd..44d32382 100644 --- a/setup.cfg +++ b/setup.cfg @@ -13,7 +13,7 @@ all_files = 1 ignore = N806, N802, N801, N803 [pep257] -ignore = D102,D104,D203,D105 +ignore = D102,D104,D203,D105,D213 [bdist_rpm] requires = amqp >= 1.4.5