Browse Source

Adds timestamp to worker/beat startup banners. Closes #3010

Ask Solem 9 years ago
parent
commit
5a718b726f
2 changed files with 7 additions and 1 deletions
  1. 4 0
      celery/apps/beat.py
  2. 3 1
      celery/apps/worker.py

+ 4 - 0
celery/apps/beat.py

@@ -16,6 +16,8 @@ import numbers
 import socket
 import sys
 
+from datetime import datetime
+
 from celery import VERSION_BANNER, platforms, beat
 from celery.five import text_t
 from celery.utils.imports import qualname
@@ -25,6 +27,7 @@ from celery.utils.timeutils import humanize_seconds
 __all__ = ['Beat']
 
 STARTUP_INFO_FMT = """
+LocalTime -> {timestamp}
 Configuration ->
     . broker -> {conninfo}
     . loader -> {loader}
@@ -124,6 +127,7 @@ class Beat(object):
         scheduler = beat.get_scheduler(lazy=True)
         return STARTUP_INFO_FMT.format(
             conninfo=self.app.connection().as_uri(),
+            timestamp=datetime.now().replace(microsecond=0),
             logfile=self.logfile or '[stderr]',
             loglevel=LOG_LEVELS[self.loglevel],
             loader=qualname(self.app.loader),

+ 3 - 1
celery/apps/worker.py

@@ -17,6 +17,7 @@ import os
 import platform as _platform
 import sys
 
+from datetime import datetime
 from functools import partial
 
 from billiard.process import current_process
@@ -69,7 +70,7 @@ ARTLINES = [
 BANNER = """\
 {hostname} v{version}
 
-{platform}
+{platform} {timestamp}
 
 [config]
 .> app:         {app}
@@ -202,6 +203,7 @@ class Worker(WorkController):
         banner = BANNER.format(
             app=appr,
             hostname=safe_str(self.hostname),
+            timestamp=datetime.now().replace(microsecond=0),
             version=VERSION_BANNER,
             conninfo=self.app.connection().as_uri(),
             results=maybe_sanitize_url(