|
@@ -49,7 +49,6 @@ __all__ = [
|
|
]
|
|
]
|
|
|
|
|
|
logger = get_logger(__name__)
|
|
logger = get_logger(__name__)
|
|
-info = logger.info
|
|
|
|
|
|
|
|
#: Format string used to log task success.
|
|
#: Format string used to log task success.
|
|
LOG_SUCCESS = """\
|
|
LOG_SUCCESS = """\
|
|
@@ -116,6 +115,14 @@ _patched = {}
|
|
trace_ok_t = namedtuple('trace_ok_t', ('retval', 'info', 'runtime', 'retstr'))
|
|
trace_ok_t = namedtuple('trace_ok_t', ('retval', 'info', 'runtime', 'retstr'))
|
|
|
|
|
|
|
|
|
|
|
|
+def info(fmt, context):
|
|
|
|
+ """Log 'fmt % context' with severity 'INFO'.
|
|
|
|
+
|
|
|
|
+ 'context' is also passed in extra with key 'data' for custom handlers.
|
|
|
|
+ """
|
|
|
|
+ logger.info(fmt, context, extra={'data': context})
|
|
|
|
+
|
|
|
|
+
|
|
def task_has_custom(task, attr):
|
|
def task_has_custom(task, attr):
|
|
"""Return true if the task overrides ``attr``."""
|
|
"""Return true if the task overrides ``attr``."""
|
|
return mro_lookup(task.__class__, attr, stop={BaseTask, object},
|
|
return mro_lookup(task.__class__, attr, stop={BaseTask, object},
|