mirror of https://github.com/celery/kombu.git
Tests pass on Python 2.5
This commit is contained in:
parent
b0c69f8e28
commit
502d7be2fc
|
@ -9,6 +9,7 @@ Broker connection and pools.
|
||||||
|
|
||||||
"""
|
"""
|
||||||
from __future__ import absolute_import
|
from __future__ import absolute_import
|
||||||
|
from __future__ import with_statement
|
||||||
|
|
||||||
import os
|
import os
|
||||||
import sys
|
import sys
|
||||||
|
|
|
@ -4,9 +4,8 @@ import os
|
||||||
import logging
|
import logging
|
||||||
import sys
|
import sys
|
||||||
|
|
||||||
from logging.handlers import WatchedFileHandler
|
|
||||||
|
|
||||||
from .utils import cached_property
|
from .utils import cached_property
|
||||||
|
from .utils.compat import WatchedFileHandler
|
||||||
from .utils.encoding import safe_repr, safe_str
|
from .utils.encoding import safe_repr, safe_str
|
||||||
from .utils.functional import maybe_promise
|
from .utils.functional import maybe_promise
|
||||||
|
|
||||||
|
|
|
@ -33,8 +33,8 @@ moduleindex = ("kombu.abstract",
|
||||||
def setup():
|
def setup():
|
||||||
# so coverage sees all our modules.
|
# so coverage sees all our modules.
|
||||||
for module in moduleindex:
|
for module in moduleindex:
|
||||||
|
print("preimporting %r for coverage..." % (module, ))
|
||||||
try:
|
try:
|
||||||
print("IMPORT: %r" % (module, ))
|
|
||||||
__import__(module)
|
__import__(module)
|
||||||
except ImportError:
|
except ImportError:
|
||||||
pass
|
pass
|
||||||
|
|
|
@ -252,10 +252,12 @@ class LifoQueue(Queue):
|
||||||
return self.queue.pop()
|
return self.queue.pop()
|
||||||
|
|
||||||
############## logging.handlers.WatchedFileHandler ##########################
|
############## logging.handlers.WatchedFileHandler ##########################
|
||||||
|
import logging
|
||||||
import os
|
import os
|
||||||
from stat import ST_DEV, ST_INO
|
|
||||||
import platform as _platform
|
import platform as _platform
|
||||||
|
|
||||||
|
from stat import ST_DEV, ST_INO
|
||||||
|
|
||||||
if _platform.system() == "Windows":
|
if _platform.system() == "Windows":
|
||||||
#since windows doesn't go with WatchedFileHandler use FileHandler instead
|
#since windows doesn't go with WatchedFileHandler use FileHandler instead
|
||||||
WatchedFileHandler = logging.FileHandler
|
WatchedFileHandler = logging.FileHandler
|
||||||
|
|
Loading…
Reference in New Issue