Removed debian/patches/disable-kombu-3-test.patch

debian/patches/disable-kombu-3-test.patch

@@ -1,94 +0,0 @@
-Description: Disable test that requires Kombu 3.x
- The file taskflow/tests/unit/worker_based/test_dispatcher.py is trying to
- do "from kombu import message", which is only in Kombu 3.x. Juno is to be
- released with Kombu 2.5.x, which doesn't include a message.py file, so the
- unit tests are failing.
- .
- This patch neutralise the test cases, which otherwise pass.
-Author: Thomas Goirand <zigo@debian.org>
-Forwarded: no
-Last-Update: 2015-02-10
-
---- a/taskflow/tests/unit/worker_based/test_dispatcher.py	2015-02-10 15:58:00.000000000 +0100
-+++ /dev/null	2015-02-06 22:50:20.582883760 +0100
-@@ -1,80 +0,0 @@
--# -*- coding: utf-8 -*-
--
--#    Copyright (C) 2014 Yahoo! Inc. All Rights Reserved.
--#
--#    Licensed under the Apache License, Version 2.0 (the "License"); you may
--#    not use this file except in compliance with the License. You may obtain
--#    a copy of the License at
--#
--#         http://www.apache.org/licenses/LICENSE-2.0
--#
--#    Unless required by applicable law or agreed to in writing, software
--#    distributed under the License is distributed on an "AS IS" BASIS, WITHOUT
--#    WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the
--#    License for the specific language governing permissions and limitations
--#    under the License.
--
--try:
--    from kombu import message  # noqa
--except ImportError:
--    from kombu.transport import base as message
--
--from taskflow.engines.worker_based import dispatcher
--from taskflow import test
--from taskflow.test import mock
--
--
--def mock_acked_message(ack_ok=True, **kwargs):
--    msg = mock.create_autospec(message.Message, spec_set=True, instance=True,
--                               channel=None, **kwargs)
--
--    def ack_side_effect(*args, **kwargs):
--        msg.acknowledged = True
--
--    if ack_ok:
--        msg.ack_log_error.side_effect = ack_side_effect
--    msg.acknowledged = False
--    return msg
--
--
--class TestDispatcher(test.TestCase):
--    def test_creation(self):
--        on_hello = mock.MagicMock()
--        handlers = {'hello': on_hello}
--        dispatcher.TypeDispatcher(type_handlers=handlers)
--
--    def test_on_message(self):
--        on_hello = mock.MagicMock()
--        handlers = {'hello': on_hello}
--        d = dispatcher.TypeDispatcher(type_handlers=handlers)
--        msg = mock_acked_message(properties={'type': 'hello'})
--        d.on_message("", msg)
--        self.assertTrue(on_hello.called)
--        self.assertTrue(msg.ack_log_error.called)
--        self.assertTrue(msg.acknowledged)
--
--    def test_on_rejected_message(self):
--        d = dispatcher.TypeDispatcher()
--        msg = mock_acked_message(properties={'type': 'hello'})
--        d.on_message("", msg)
--        self.assertTrue(msg.reject_log_error.called)
--        self.assertFalse(msg.acknowledged)
--
--    def test_on_requeue_message(self):
--        d = dispatcher.TypeDispatcher()
--        d.requeue_filters.append(lambda data, message: True)
--        msg = mock_acked_message()
--        d.on_message("", msg)
--        self.assertTrue(msg.requeue.called)
--        self.assertFalse(msg.acknowledged)
--
--    def test_failed_ack(self):
--        on_hello = mock.MagicMock()
--        handlers = {'hello': on_hello}
--        d = dispatcher.TypeDispatcher(type_handlers=handlers)
--        msg = mock_acked_message(ack_ok=False,
--                                 properties={'type': 'hello'})
--        d.on_message("", msg)
--        self.assertTrue(msg.ack_log_error.called)
--        self.assertFalse(msg.acknowledged)
--        self.assertFalse(on_hello.called)

debian/patches/series

@@ -1 +0,0 @@
-disable-kombu-3-test.patch