salt/tests/integration/reactor/test_reactor.py

39 lines
916 B
Python

# -*- coding: utf-8 -*-
'''
integration.reactor.reactor
~~~~~~~~~~~~~~~~~~~~~~~~~~~
Test Salt's reactor system
'''
# Import Python libs
from __future__ import absolute_import
# Import Salt testing libs
from tests.support.case import ModuleCase
from tests.support.helpers import flaky
from tests.support.mixins import SaltMinionEventAssertsMixin
# Import Salt libs
import salt.utils.event
class ReactorTest(ModuleCase, SaltMinionEventAssertsMixin):
'''
Test Salt's reactor system
'''
@flaky()
def test_ping_reaction(self):
'''
Fire an event on the master and ensure
that it pings the minion
'''
# Create event bus connection
e = salt.utils.event.get_event('minion', sock_dir=self.minion_opts['sock_dir'], opts=self.minion_opts)
e.fire_event({'a': 'b'}, '/test_event')
self.assertMinionEventReceived({'a': 'b'})