|
@@ -17,6 +17,7 @@ import socket
|
|
import sys
|
|
import sys
|
|
|
|
|
|
from celery import VERSION_BANNER, platforms, beat
|
|
from celery import VERSION_BANNER, platforms, beat
|
|
|
|
+from celery.five import text_t
|
|
from celery.utils.imports import qualname
|
|
from celery.utils.imports import qualname
|
|
from celery.utils.log import LOG_LEVELS, get_logger
|
|
from celery.utils.log import LOG_LEVELS, get_logger
|
|
from celery.utils.timeutils import humanize_seconds
|
|
from celery.utils.timeutils import humanize_seconds
|
|
@@ -98,10 +99,12 @@ class Beat(object):
|
|
scheduler_cls=self.scheduler_cls,
|
|
scheduler_cls=self.scheduler_cls,
|
|
schedule_filename=self.schedule)
|
|
schedule_filename=self.schedule)
|
|
|
|
|
|
- print(unicode(c.blue('__ ', c.magenta('-'),
|
|
|
|
- c.blue(' ... __ '), c.magenta('-'),
|
|
|
|
- c.blue(' _\n'),
|
|
|
|
- c.reset(self.startup_info(beat)))))
|
|
|
|
|
|
+ print(text_t(
|
|
|
|
+ c.blue('__ ', c.magenta('-'),
|
|
|
|
+ c.blue(' ... __ '), c.magenta('-'),
|
|
|
|
+ c.blue(' _\n'),
|
|
|
|
+ c.reset(self.startup_info(beat))),
|
|
|
|
+ ))
|
|
self.setup_logging()
|
|
self.setup_logging()
|
|
if self.socket_timeout:
|
|
if self.socket_timeout:
|
|
logger.debug('Setting default socket timeout to %r',
|
|
logger.debug('Setting default socket timeout to %r',
|