|
@@ -2,6 +2,7 @@ from __future__ import absolute_import
|
|
|
from __future__ import with_statement
|
|
|
|
|
|
import socket
|
|
|
+import sys
|
|
|
|
|
|
from collections import deque
|
|
|
from datetime import datetime, timedelta
|
|
@@ -463,6 +464,8 @@ class test_Consumer(Case):
|
|
|
self.assertIs(self.ready_queue.get_nowait(), task)
|
|
|
|
|
|
def test_receieve_message_eta_isoformat(self):
|
|
|
+ if sys.version_info < (2, 6):
|
|
|
+ raise SkipTest('test broken on Python 2.5')
|
|
|
l = MyKombuConsumer(self.ready_queue, timer=self.timer)
|
|
|
m = create_message(Mock(), task=foo_task.name,
|
|
|
eta=datetime.now().isoformat(),
|