diff --git a/tests/integration/test_analysisd/test_queue_socket_status/test_queue_socket_status.py b/tests/integration/test_analysisd/test_queue_socket_status/test_queue_socket_status.py index ac3daac5f8..4a73792a05 100644 --- a/tests/integration/test_analysisd/test_queue_socket_status/test_queue_socket_status.py +++ b/tests/integration/test_analysisd/test_queue_socket_status/test_queue_socket_status.py @@ -3,6 +3,8 @@ import subprocess from wazuh_testing.tools import WAZUH_PATH +from wazuh_testing.tools.services import control_service, check_daemon_status + # Marks @@ -15,11 +17,21 @@ command_exec = f'{analysisd_path} -t' - def test_queue_socket_status(): + + # Check if analysisd daemon is running + check_daemon_status(running_condition=True, target_daemon='wazuh-analysisd') + current_inode_file = os.stat(ANALYSISD_SOCKET).st_ino current_status_time = os.path.getmtime(ANALYSISD_SOCKET) + # Stop analysisd daemon + control_service('stop', daemon='wazuh-analysisd') + check_daemon_status(running_condition=False, target_daemon='wazuh-analysisd') + + control_service('start', daemon='wazuh-analysisd') + + # Updating Analysisd run = subprocess.Popen(['/bin/bash', '-c', command_exec]) run.communicate()