diff options
| author | Sergey Lukjanov <slukjanov@mirantis.com> | 2013-06-02 20:41:20 +0400 |
|---|---|---|
| committer | Sergey Lukjanov <slukjanov@mirantis.com> | 2013-06-03 07:53:21 +0400 |
| commit | e3545f828dabe165dc08b2f1670e5f1f19919d0d (patch) | |
| tree | ead970c643632ed624c6bda25e902f47cf13b49e /tests/unit/rpc | |
| parent | 15d8d698b7c67c43dc7a2b0c2c6952734bd2ba66 (diff) | |
Enable hacking H402 test
H402 one line docstring needs punctuation
Change-Id: Ie848453cace318d8310cdf0234c512f4c1121119
Diffstat (limited to 'tests/unit/rpc')
| -rw-r--r-- | tests/unit/rpc/amqp.py | 2 | ||||
| -rw-r--r-- | tests/unit/rpc/test_kombu.py | 16 | ||||
| -rw-r--r-- | tests/unit/rpc/test_service.py | 4 |
3 files changed, 11 insertions, 11 deletions
diff --git a/tests/unit/rpc/amqp.py b/tests/unit/rpc/amqp.py index 69d647a..432dd35 100644 --- a/tests/unit/rpc/amqp.py +++ b/tests/unit/rpc/amqp.py @@ -223,7 +223,7 @@ class BaseRpcAMQPTestCase(common.BaseRpcTestCase): self.config(amqp_rpc_single_reply_queue=False) def test_duplicate_message_check(self): - """Test sending *not-dict* to a topic exchange/queue""" + """Test sending *not-dict* to a topic exchange/queue.""" conn = self.rpc.create_connection(FLAGS) message = {'args': 'topic test message', '_unique_id': 'aaaabbbbcccc'} diff --git a/tests/unit/rpc/test_kombu.py b/tests/unit/rpc/test_kombu.py index a524c73..159fefb 100644 --- a/tests/unit/rpc/test_kombu.py +++ b/tests/unit/rpc/test_kombu.py @@ -95,7 +95,7 @@ class RpcKombuTestCase(amqp.BaseRpcAMQPTestCase): self.assertEqual(conn1, conn2) def test_topic_send_receive(self): - """Test sending to a topic exchange/queue""" + """Test sending to a topic exchange/queue.""" conn = self.rpc.create_connection(FLAGS) message = 'topic test message' @@ -132,7 +132,7 @@ class RpcKombuTestCase(amqp.BaseRpcAMQPTestCase): conn.close() def test_topic_send_receive_exchange_name(self): - """Test sending to a topic exchange/queue with an exchange name""" + """Test sending to a topic exchange/queue with an exchange name.""" conn = self.rpc.create_connection(FLAGS) message = 'topic test message' @@ -151,7 +151,7 @@ class RpcKombuTestCase(amqp.BaseRpcAMQPTestCase): self.assertEqual(self.received_message, message) def test_topic_multiple_queues(self): - """Test sending to a topic exchange with multiple queues""" + """Test sending to a topic exchange with multiple queues.""" conn = self.rpc.create_connection(FLAGS) message = 'topic test message' @@ -233,7 +233,7 @@ class RpcKombuTestCase(amqp.BaseRpcAMQPTestCase): self.assertEqual(self.received_message_2, message) def test_direct_send_receive(self): - """Test sending to a direct exchange/queue""" + """Test sending to a direct exchange/queue.""" conn = self.rpc.create_connection(FLAGS) message = 'direct test message' @@ -250,7 +250,7 @@ class RpcKombuTestCase(amqp.BaseRpcAMQPTestCase): self.assertEqual(self.received_message, message) def test_cast_interface_uses_default_options(self): - """Test kombu rpc.cast""" + """Test kombu rpc.cast.""" ctxt = rpc_common.CommonRpcContext(user='fake_user', project='fake_project') @@ -276,7 +276,7 @@ class RpcKombuTestCase(amqp.BaseRpcAMQPTestCase): impl_kombu.cast(FLAGS, ctxt, 'fake_topic', {'msg': 'fake'}) def test_cast_to_server_uses_server_params(self): - """Test kombu rpc.cast""" + """Test kombu rpc.cast.""" ctxt = rpc_common.CommonRpcContext(user='fake_user', project='fake_project') @@ -309,7 +309,7 @@ class RpcKombuTestCase(amqp.BaseRpcAMQPTestCase): 'fake_topic', {'msg': 'fake'}) def test_fanout_send_receive(self): - """Test sending to a fanout exchange and consuming from 2 queues""" + """Test sending to a fanout exchange and consuming from 2 queues.""" self.skipTest("kombu memory transport seems buggy with " "fanout queues as this test passes when " @@ -366,7 +366,7 @@ class RpcKombuTestCase(amqp.BaseRpcAMQPTestCase): self.assertTrue(isinstance(result, self.rpc.DirectConsumer)) def test_declare_consumer_ioerrors_will_reconnect(self): - """Test that an IOError exception causes a reconnection""" + """Test that an IOError exception causes a reconnection.""" info = _raise_exc_stub(self.stubs, 2, self.rpc.DirectConsumer, '__init__', 'Socket closed', exc_class=IOError) diff --git a/tests/unit/rpc/test_service.py b/tests/unit/rpc/test_service.py index 9293d3e..e9f8313 100644 --- a/tests/unit/rpc/test_service.py +++ b/tests/unit/rpc/test_service.py @@ -21,7 +21,7 @@ from tests import utils class FakeService(service.Service): - """Fake manager for tests""" + """Fake manager for tests.""" def __init__(self, host, topic): super(FakeService, self).__init__(host, topic, None) self.method_result = 'manager' @@ -43,7 +43,7 @@ class FakeHookService(FakeService): class RpcServiceManagerTestCase(utils.BaseTestCase): - """Test cases for Services""" + """Test cases for Services.""" def setUp(self): super(RpcServiceManagerTestCase, self).setUp() self.config(fake_rabbit=True) |
