st2actions.cmd._run_worker() - Code Metrics - Inspection of "Kale/action datastore" - Plexxi/st2 - Measure and Improve Code Quality continuously with Scrutinizer

Completed

Pull Request — master (#5)

unknown

created 2016-01-15 17:35 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	14
rs	9.4285

import eventlet
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 st2actions.notifier import config
from st2actions.notifier import notifier
from st2actions.notifier import scheduler


LOG = logging.getLogger(__name__)


eventlet.monkey_patch(
    os=True,
    select=True,
    socket=True,
    thread=False if '--use-debugger' in sys.argv else True,
    time=True)


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


def _run_worker():
    LOG.info('(PID=%s) Actions notifier started.', os.getpid())
    actions_notifier = notifier.get_notifier()
    actions_rescheduler = scheduler.get_rescheduler()
    try:
        eventlet.spawn(actions_rescheduler.start)
        actions_notifier.start(wait=True)
    except (KeyboardInterrupt, SystemExit):
        LOG.info('(PID=%s) Actions notifier stopped.', os.getpid())
        actions_rescheduler.shutdown()
        actions_notifier.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 eventlet
2			import os
3			import sys
4
5			from st2common import log as logging
6			from st2common.service_setup import setup as common_setup
7			from st2common.service_setup import teardown as common_teardown
8			from st2actions.notifier import config
9			from st2actions.notifier import notifier
10			from st2actions.notifier import scheduler
11
12
13			LOG = logging.getLogger(__name__)
14
15
16			eventlet.monkey_patch(
17			os=True,
18			select=True,
19			socket=True,
20			thread=False if '--use-debugger' in sys.argv else True,
21			time=True)
22
23
24			def _setup():
25			common_setup(service='notifier', config=config, setup_db=True, register_mq_exchanges=True,
26			register_signal_handlers=True)
27
28
29			def _run_worker():
30			LOG.info('(PID=%s) Actions notifier started.', os.getpid())
31			actions_notifier = notifier.get_notifier()
32			actions_rescheduler = scheduler.get_rescheduler()
33			try:
34			eventlet.spawn(actions_rescheduler.start)
35			actions_notifier.start(wait=True)
36			except (KeyboardInterrupt, SystemExit):
37			LOG.info('(PID=%s) Actions notifier stopped.', os.getpid())
38			actions_rescheduler.shutdown()
39			actions_notifier.shutdown()
40			except:
41			return 1
42			return 0
43
44
45			def _teardown():
46			common_teardown()
47
48
49			def main():
50			try:
51			_setup()
52			return _run_worker()
53			except SystemExit as exit_code:
54			sys.exit(exit_code)
55			except:
56			LOG.exception('(PID=%s) Results tracker quit due to exception.', os.getpid())
57			return 1
58			finally:
59			_teardown()
60

Plexxi / st2

GitHub Access Token became invalid

Pull Request — master (#5)

st2actions.cmd._run_worker() A

Complexity

Size

Duplication

Duplication Side-by-Side

Filter issues like