From c457a884591b1bc2b284d8cdafb3b0e6521c15f6 Mon Sep 17 00:00:00 2001 From: Ask Solem Date: Tue, 11 Oct 2016 14:59:00 -0700 Subject: [PATCH] pep257 -> pydocstyle --- kombu/transport/etcd.py | 9 +++------ requirements/pkgutils.txt | 2 +- setup.cfg | 2 +- 3 files changed, 5 insertions(+), 8 deletions(-) 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