monkey.patch_all()
import logging
-logging.basicConfig(level=logging.INFO, format='%(asctime)s.%(msecs)03d %(levelname)s:%(name)s:%(message)s')
+
+logging.basicConfig(
+ level=logging.INFO,
+ format='%(asctime)s.%(msecs)03d %(levelname)s:%(name)s:%(message)s')
log = logging.getLogger(__name__)
+
+
+def setup_log_file(logger, log_path):
+ log_formatter = logging.Formatter(
+ fmt=u'%(asctime)s.%(msecs)03d %(levelname)s:%(name)s:%(message)s',
+ datefmt='%Y-%m-%dT%H:%M:%S')
+ log_handler = logging.FileHandler(filename=log_path)
+ log_handler.setFormatter(log_formatter)
+ logger.addHandler(log_handler)
read_config(args)
- handler = logging.FileHandler(
- filename=os.path.join(args.test_dir, 'coverage.log'),
- )
- formatter = logging.Formatter(
- fmt=u'%(asctime)s.%(msecs)03d %(levelname)s:%(message)s',
- datefmt='%Y-%m-%dT%H:%M:%S',
- )
- handler.setFormatter(formatter)
- logging.getLogger().addHandler(handler)
+ log_path = os.path.join(args.test_dir, 'coverage.log')
+ teuthology.setup_log_file(log, log_path)
try:
analyze(args)
misc.read_config(args)
- handler = logging.FileHandler(
- filename=os.path.join(args.archive_dir, 'results.log'),
- )
- formatter = logging.Formatter(
- fmt=u'%(asctime)s.%(msecs)03d %(levelname)s:%(message)s',
- datefmt='%Y-%m-%dT%H:%M:%S',
- )
- handler.setFormatter(formatter)
- logging.getLogger().addHandler(handler)
+ log_path = os.path.join(args.archive_dir, 'results.log')
+ teuthology.setup_log_file(log, log_path)
try:
results(args)
if ctx.archive is not None:
os.mkdir(ctx.archive)
- handler = logging.FileHandler(
- filename=os.path.join(ctx.archive, 'teuthology.log'),
- )
- formatter = logging.Formatter(
- fmt=u'%(asctime)s.%(msecs)03d %(levelname)s:%(name)s:%(message)s',
- datefmt='%Y-%m-%dT%H:%M:%S',
- )
- handler.setFormatter(formatter)
- logging.getLogger().addHandler(handler)
+ teuthology.setup_log_file(
+ logging.getLogger(),
+ os.path.join(ctx.archive, 'teuthology.log'))
install_except_hook()
from datetime import datetime
+from teuthology import setup_log_file
from . import beanstalk
from . import report
from . import safepath
log_file_path = os.path.join(ctx.log_dir, 'worker.{tube}.{pid}'.format(
pid=os.getpid(), tube=ctx.tube,))
- log_handler = logging.FileHandler(filename=log_file_path)
- log_formatter = logging.Formatter(
- fmt=u'%(asctime)s.%(msecs)03d %(levelname)s:%(name)s:%(message)s',
- datefmt='%Y-%m-%dT%H:%M:%S')
- log_handler.setFormatter(log_formatter)
- log.addHandler(log_handler)
+ setup_log_file(log, log_file_path)
if not os.path.isdir(ctx.archive_dir):
sys.exit("{prog}: archive directory must exist: {path}".format(