st2actions.cmd._run_worker() - Code Metrics - Inspection of "Add pytests to circle.yml" - StackStorm/st2 - Measure and Improve Code Quality continuously with Scrutinizer

Completed

Pull Request — master (#2598)

by Manas

created 2016-03-25 21:55 UTC

st2actions.cmd._run_worker() A

↳ Parent: Project

Complexity

Conditions

Size

Total Lines

Duplication

Lines	0
Ratio	0 %

Metric	Value
cc	3
dl	0
loc	11
rs	9.4285

import os
import sys

from st2common import log as logging
from st2common.service_setup import setup as common_setup
from st2common.service_setup import teardown as common_teardown
from st2common.util.monkey_patch import monkey_patch
from st2actions.resultstracker import config
from st2actions.resultstracker import resultstracker

__all__ = [
    'main'
]


monkey_patch()

LOG = logging.getLogger(__name__)


def _setup():
    common_setup(service='resultstracker', config=config, setup_db=True,
                 register_mq_exchanges=True, register_signal_handlers=True)


def _run_worker():
    LOG.info('(PID=%s) Results tracker started.', os.getpid())
    tracker = resultstracker.get_tracker()
    try:
        tracker.start(wait=True)
    except (KeyboardInterrupt, SystemExit):
        LOG.info('(PID=%s) Results tracker stopped.', os.getpid())
        tracker.shutdown()
    except:
        return 1
    return 0


def _teardown():
    common_teardown()


def main():
    try:
        _setup()
        return _run_worker()
    except SystemExit as exit_code:
        sys.exit(exit_code)
    except:
        LOG.exception('(PID=%s) Results tracker quit due to exception.', os.getpid())
        return 1
    finally:
        _teardown()


1			import os
2			import sys
3
4			from st2common import log as logging
5			from st2common.service_setup import setup as common_setup
6			from st2common.service_setup import teardown as common_teardown
7			from st2common.util.monkey_patch import monkey_patch
8			from st2actions.resultstracker import config
9			from st2actions.resultstracker import resultstracker
10
11			__all__ = [
12			'main'
13			]
14
15
16			monkey_patch()
17
18			LOG = logging.getLogger(__name__)
19
20
21			def _setup():
22			common_setup(service='resultstracker', config=config, setup_db=True,
23			register_mq_exchanges=True, register_signal_handlers=True)
24
25
26			def _run_worker():
27			LOG.info('(PID=%s) Results tracker started.', os.getpid())
28			tracker = resultstracker.get_tracker()
29			try:
30			tracker.start(wait=True)
31			except (KeyboardInterrupt, SystemExit):
32			LOG.info('(PID=%s) Results tracker stopped.', os.getpid())
33			tracker.shutdown()
34			except:
35			return 1
36			return 0
37
38
39			def _teardown():
40			common_teardown()
41
42
43			def main():
44			try:
45			_setup()
46			return _run_worker()
47			except SystemExit as exit_code:
48			sys.exit(exit_code)
49			except:
50			LOG.exception('(PID=%s) Results tracker quit due to exception.', os.getpid())
51			return 1
52			finally:
53			_teardown()
54

StackStorm / st2

Pull Request — master (#2598)

st2actions.cmd._run_worker() A

Complexity

Size

Duplication

Duplication Side-by-Side

Filter issues like