from rmqbeat import BaseTest

import os


class Test(BaseTest):

    def test_base(self):
        """
        Basic test with exiting Rmqbeat normally
        """
        self.render_config_template(
            path=os.path.abspath(self.working_dir) + "/log/*"
        )

        rmqbeat_proc = self.start_beat()
        self.wait_until(lambda: self.log_contains("rmqbeat is running"))
        exit_code = rmqbeat_proc.kill_and_wait()
        assert exit_code == 0

from rmqbeat import BaseTest

import os


class Test(BaseTest):

    def test_base(self):
        """
        Basic test with exiting Rmqbeat normally
        """
        self.render_config_template(
            path=os.path.abspath(self.working_dir) + "/log/*"
        )

        rmqbeat_proc = self.start_beat()
        self.wait_until(lambda: self.log_contains("rmqbeat is running"))
        exit_code = rmqbeat_proc.kill_and_wait()
        assert exit_code == 0

Basic test with exiting Rmqbeat normally