From f58c50f383f7cada4fc8cf4c278b8b1e1a10a801 Mon Sep 17 00:00:00 2001
From: David Boucher <dboucher@centreon.com>
Date: Wed, 28 Feb 2024 10:53:07 +0100
Subject: [PATCH] fix(tests): Coding style of Engine improved

---
 tests/resources/Broker.py |  323 +++++------
 tests/resources/Engine.py | 1150 +++++++++++++++++++------------------
 2 files changed, 741 insertions(+), 732 deletions(-)

diff --git a/tests/resources/Broker.py b/tests/resources/Broker.py
index 591da4fd771..c92480ac4b7 100755
--- a/tests/resources/Broker.py
+++ b/tests/resources/Broker.py
@@ -1,16 +1,12 @@
 import signal
 from os import setsid
 from os import makedirs
-from os.path import exists, dirname
+from os.path import exists
 import pymysql.cursors
 import time
 import re
 import shutil
 import psutil
-import socket
-import sys
-import time
-from datetime import datetime
 from subprocess import getoutput
 import subprocess as subp
 from robot.api import logger
@@ -22,7 +18,6 @@
 import broker_pb2_grpc
 from google.protobuf import empty_pb2
 from google.protobuf.json_format import MessageToJson
-from robot.libraries.BuiltIn import BuiltIn
 from Common import DB_NAME_STORAGE, DB_NAME_CONF, DB_USER, DB_PASS, DB_HOST, DB_PORT, VAR_ROOT, ETC_ROOT, TESTS_PARAMS
 
 TIMEOUT = 30
@@ -414,7 +409,7 @@ def _apply_conf(name, callback):
 
 def config_broker(name: str, poller_inst: int = 1):
     """
-    
+
     config_broker 
 
     Configure broker instances for test. Write the configuration files.
@@ -424,8 +419,8 @@ def config_broker(name: str, poller_inst: int = 1):
         poller_inst (int, optional): Defaults to 1.
 
     Returns: create  conf broker with the chosen name
-        
-    """    
+
+    """
     makedirs(ETC_ROOT, mode=0o777, exist_ok=True)
     makedirs(VAR_ROOT, mode=0o777, exist_ok=True)
     makedirs(ETC_ROOT + "/centreon-broker", mode=0o777, exist_ok=True)
@@ -500,7 +495,7 @@ def config_broker(name: str, poller_inst: int = 1):
 
 def change_broker_tcp_output_to_grpc(name: str):
     """
-    
+
     change_broker_tcp_output_to_grpc 
 
     Update broker configuration to use a gRPC output instead of a TCP one.
@@ -509,8 +504,8 @@ def change_broker_tcp_output_to_grpc(name: str):
         name (str): name of the conf broker wanted to be changed
 
     Returns: N/A
-        
-    """    
+
+    """
     def output_to_grpc(conf):
         output_dict = conf["centreonBroker"]["output"]
         for i, v in enumerate(output_dict):
@@ -532,8 +527,8 @@ def add_path_to_rrd_output(name: str, path: str):
         path (str): path to the rrd output (/tmp/rrd)
 
     Returns: N/A
-        
-    """    
+
+    """
     def rrd_output(conf):
         output_dict = conf["centreonBroker"]["output"]
         for i, v in enumerate(output_dict):
@@ -552,8 +547,8 @@ def change_broker_tcp_input_to_grpc(name: str):
         name (str): input name
 
     Returns: N/A
-      
-    """    
+
+    """
     def input_to_grpc(conf):
         input_dict = conf["centreonBroker"]["input"]
         for i, v in enumerate(input_dict):
@@ -568,27 +563,26 @@ def _add_broker_crypto(json_dict, add_cert: bool, only_ca_cert: bool):
     json_dict["encryption"] = "yes"
     if (add_cert):
         json_dict["ca_certificate"] = "/tmp/ca_1234.crt"
-        if (only_ca_cert == False):
+        if only_ca_cert is False:
             json_dict["public_cert"] = "/tmp/server_1234.crt"
             json_dict["private_key"] = "/tmp/server_1234.key"
 
 
 def add_broker_tcp_input_grpc_crypto(name: str, add_cert: bool, reversed: bool):
-    """    
-    add_broker_tcp_input_grpc_crypto 
+    """
+    add_broker_tcp_input_grpc_crypto
 
     Add grpc crypto to broker tcp input
 
     Args:
-        name (str): 
-        add_cert (bool): 
-        reversed (bool): 
+        name (str):
+        add_cert (bool):
+        reversed (bool):
     Example:
     | Add Broker Tcp Input Grpc Crypto | central | ${True} | ${False} |
 
     Returns: N/A
-        
-    """    
+    """
     def _crypto_modifier(conf):
         input_dict = conf["centreonBroker"]["input"]
         for i, v in enumerate(input_dict):
@@ -612,8 +606,8 @@ def add_broker_tcp_output_grpc_crypto(name: str, add_cert: bool, reversed: bool)
     | Add Broker Tcp Output Grpc Crypto | module0 | ${True} | ${False} |
 
     Returns: N/A
-        
-    """    
+
+    """
     def _crypto_modifier(conf):
         input_dict = conf["centreonBroker"]["output"]
         for i, v in enumerate(input_dict):
@@ -624,7 +618,7 @@ def _crypto_modifier(conf):
 
 def add_host_to_broker_output(name: str, output_name: str, host_ip: str):
     """
-    
+
     add_host_to_broker_output 
 
     Add host to broker output
@@ -638,8 +632,8 @@ def add_host_to_broker_output(name: str, output_name: str, host_ip: str):
     | Add Host To Broker Output | module0 | central-module-master-output | localhost |
 
     Returns: N/A
-        
-    """    
+
+    """
     def modifier(conf):
         input_dict = conf["centreonBroker"]["output"]
         for i, v in enumerate(input_dict):
@@ -650,7 +644,7 @@ def modifier(conf):
 
 def add_host_to_broker_input(name: str, input_name: str, host_ip: str):
     """
-    
+
     add_host_to_broker_input 
 
     Add host to broker input
@@ -664,8 +658,8 @@ def add_host_to_broker_input(name: str, input_name: str, host_ip: str):
     | Add Host To Broker Input | central | central-broker-master-input | localhost |
 
     Returns: N/A
-       
-    """    
+
+    """
     def modifier(conf):
         input_dict = conf["centreonBroker"]["input"]
         for i, v in enumerate(input_dict):
@@ -676,7 +670,7 @@ def modifier(conf):
 
 def remove_host_from_broker_output(name: str, output_name: str):
     """
-    
+
     remove_host_from_broker_output 
 
     Remove host from broker output
@@ -689,8 +683,8 @@ def remove_host_from_broker_output(name: str, output_name: str):
     | Remove Host From Broker Output | module0 | central-module-master-output |
 
     Returns: N/A
-        
-    """    
+
+    """
     def modifier(conf):
         input_dict = conf["centreonBroker"]["output"]
         for i, v in enumerate(input_dict):
@@ -701,7 +695,7 @@ def modifier(conf):
 
 def remove_host_from_broker_input(name: str, input_name: str):
     """
-    
+
     remove_host_from_broker_input 
 
     Remove host from broker input
@@ -714,8 +708,8 @@ def remove_host_from_broker_input(name: str, input_name: str):
     | Remove Host From Broker Input | central | central-broker-master-input |
 
     Returns: N/A
-        
-    """    
+
+    """
     def modifier(conf):
         input_dict = conf["centreonBroker"]["input"]
         for i, v in enumerate(input_dict):
@@ -726,7 +720,7 @@ def modifier(conf):
 
 def change_broker_compression_output(config_name: str, output_name: str, compression_value: str):
     """
-    
+
     change_broker_compression_output 
 
     Update broker configuration compression output
@@ -740,8 +734,8 @@ def change_broker_compression_output(config_name: str, output_name: str, compres
     | Change Broker Compression Output | module0 | central-module-master-output | yes |
 
     Returns: N/A
-        
-    """    
+
+    """
     def compression_modifier(conf):
         output_dict = conf["centreonBroker"]["output"]
         for i, v in enumerate(output_dict):
@@ -752,7 +746,7 @@ def compression_modifier(conf):
 
 def change_broker_compression_input(config_name: str, input_name: str, compression_value: str):
     """
-    
+
     change_broker_compression_input 
 
     Update broker configuration compression input
@@ -766,8 +760,8 @@ def change_broker_compression_input(config_name: str, input_name: str, compressi
     | Change Broker Compression Input | central | central-broker-master-input | yes |
 
     Returns: N/A
-        
-    """    
+
+    """
     def compression_modifier(conf):
         input_dict = conf["centreonBroker"]["input"]
         for i, v in enumerate(input_dict):
@@ -778,7 +772,7 @@ def compression_modifier(conf):
 
 def config_broker_remove_rrd_output(name):
     """
-    
+
     config_broker_remove_rrd_output 
 
     Remove rrd output from broker configuration
@@ -790,8 +784,8 @@ def config_broker_remove_rrd_output(name):
     | Config Broker Remove Rrd Output | central |
 
     Returns: N/A
-        
-    """    
+
+    """
     if name == 'central':
         filename = "central-broker.json"
     elif name.startswith('module'):
@@ -814,7 +808,7 @@ def config_broker_remove_rrd_output(name):
 
 def config_broker_bbdo_input(name, stream, port, proto, host=None):
     """
-    
+
     config_broker_bbdo_input
 
     Configure broker bbdo input
@@ -831,8 +825,8 @@ def config_broker_bbdo_input(name, stream, port, proto, host=None):
     | Config Broker Bbdo Input | rrd | bbdo_client | 5670 | tcp | localhost |
 
     Returns: N/A
-        
-    """    
+
+    """
     if stream != "bbdo_server" and stream != "bbdo_client":
         raise Exception(
             "config_broker_bbdo_input_output() function only accepts stream in ('bbdo_server', 'bbdo_client')")
@@ -872,7 +866,7 @@ def config_broker_bbdo_input(name, stream, port, proto, host=None):
 
 def config_broker_bbdo_output(name, stream, port, proto, host=None):
     """
-    
+
     config_broker_bbdo_output
 
     Configure broker bbdo output
@@ -888,8 +882,8 @@ def config_broker_bbdo_output(name, stream, port, proto, host=None):
     | Config Broker Bbdo Output | central | bbdo_server | 5670 | tcp | localhost |
 
     Returns: N/A
-        
-    """    
+
+    """
     if stream != "bbdo_server" and stream != "bbdo_client":
         raise Exception(
             "config_broker_bbdo_output() function only accepts stream in ('bbdo_server', 'bbdo_client')")
@@ -930,7 +924,7 @@ def config_broker_bbdo_output(name, stream, port, proto, host=None):
 
 def config_broker_sql_output(name, output, queries_per_transaction: int = 20000):
     """
-    
+
     config_broker_sql_output 
 
     Configure broker sql output
@@ -941,8 +935,8 @@ def config_broker_sql_output(name, output, queries_per_transaction: int = 20000)
         queries_per_transaction (int, optional): Defaults to 20000.
 
     Returns: N/A
-        
-    """    
+
+    """
     if name == 'central':
         filename = "central-broker.json"
     elif name.startswith('module'):
@@ -1023,7 +1017,7 @@ def config_broker_sql_output(name, output, queries_per_transaction: int = 20000)
 
 def broker_config_clear_outputs_except(name, ex: list):
     """
-    
+
     broker_config_clear_outputs_except
 
     Configure broker to clear outputs except the one in the list
@@ -1031,13 +1025,13 @@ def broker_config_clear_outputs_except(name, ex: list):
     Args:
         name (_type_):
         ex (list):
-    
+
     Example:
     | Broker Config Clear Outputs Except | central | ["sql", "storage"] |
 
     Returns: N/A
-        
-    """    
+
+    """
     if name == 'central':
         filename = "central-broker.json"
     elif name.startswith('module'):
@@ -1059,7 +1053,7 @@ def broker_config_clear_outputs_except(name, ex: list):
 
 def config_broker_victoria_output():
     """
-    
+
     config_broker_victoria_output 
 
     Configure broker to add victoria output
@@ -1068,8 +1062,8 @@ def config_broker_victoria_output():
     | Config Broker Victoria Output |
 
     Returns: N/A
-        
-    """    
+
+    """
     filename = "central-broker.json"
 
     with open(ETC_ROOT + "/centreon-broker/{}".format(filename), "r") as f:
@@ -1094,7 +1088,7 @@ def config_broker_victoria_output():
 
 def broker_config_add_item(name, key, value):
     """
-    
+
     broker_config_add_item 
 
     Add item to broker configuration
@@ -1108,8 +1102,8 @@ def broker_config_add_item(name, key, value):
     | Broker Config Add Item | module0 | bbdo_version | 3.0.1 |
 
     Returns: N/A
-        
-    """    
+
+    """
     if name == 'central':
         filename = "central-broker.json"
     elif name == 'rrd':
@@ -1129,7 +1123,7 @@ def broker_config_add_item(name, key, value):
 
 def broker_config_remove_item(name, key):
     """
-    
+
     broker_config_remove_item
 
     Remove item from broker configuration
@@ -1142,7 +1136,7 @@ def broker_config_remove_item(name, key):
     | Broker Config Remove Item | module0 | bbdo_version |
 
     Returns: N/A
-        
+
     """
     if name == 'central':
         filename = "central-broker.json"
@@ -1163,7 +1157,7 @@ def broker_config_remove_item(name, key):
 
 def broker_config_add_lua_output(name, output, luafile):
     """
-    
+
     broker_config_add_lua_output
 
     Add lua output to broker configuration
@@ -1177,8 +1171,8 @@ def broker_config_add_lua_output(name, output, luafile):
     | `Broker Config Add Lua Output` | central | test-protobuf | /tmp/lua.lua |
 
     Returns: N/A
-        
-    """    
+
+    """
     if name == 'central':
         filename = "central-broker.json"
     elif name.startswith('module'):
@@ -1203,7 +1197,7 @@ def broker_config_add_lua_output(name, output, luafile):
 
 def broker_config_output_set(name, output, key, value):
     """
-    
+
     broker_config_output_set 
 
     Configure broker output set.
@@ -1218,8 +1212,8 @@ def broker_config_output_set(name, output, key, value):
     | Broker Config Output Set | central | central-broker-master-sql | host | localhost |
 
     Returns: N/A
-        
-    """    
+
+    """
     if name == 'central':
         filename = "central-broker.json"
     elif name.startswith('module'):
@@ -1239,7 +1233,7 @@ def broker_config_output_set(name, output, key, value):
 
 def broker_config_output_set_json(name, output, key, value):
     """
-    
+
     broker_config_output_set_json
 
     Configure broker output set json.
@@ -1254,8 +1248,8 @@ def broker_config_output_set_json(name, output, key, value):
     | Broker Config Output Set Json | central | central-broker-master-sql | filters | {"category": ["neb", "foo", "bar"]} |
 
     Returns: N/A
-        
-    """    
+
+    """
     if name == 'central':
         filename = "central-broker.json"
     elif name.startswith('module'):
@@ -1277,7 +1271,7 @@ def broker_config_output_set_json(name, output, key, value):
 
 def broker_config_output_remove(name, output, key):
     """
-    
+
     broker_config_output_remove 
 
     Configure broker output remove.
@@ -1291,8 +1285,8 @@ def broker_config_output_remove(name, output, key):
     | Broker Config Output Remove | central | centreon-broker-master-rrd | host |
 
     Returns: N/A
-        
-    """    
+
+    """
     if name == 'central':
         filename = "central-broker.json"
     elif name.startswith('module'):
@@ -1315,7 +1309,7 @@ def broker_config_output_remove(name, output, key):
 
 def broker_config_input_set(name, inp, key, value):
     """
-    
+
     broker_config_input_set
 
     Configure broker input set.
@@ -1330,8 +1324,8 @@ def broker_config_input_set(name, inp, key, value):
     | Broker Config Input Set | rrd | rrd-broker-master-input | encryption | yes |
 
     Returns: N/A
-        
-    """    
+
+    """
     if name == 'central':
         filename = "central-broker.json"
     elif name.startswith('module'):
@@ -1373,7 +1367,7 @@ def broker_config_input_remove(name, inp, key):
 
 def broker_config_log(name, key, value):
     """
-    
+
     broker_config_log
 
     Configure broker log level.
@@ -1387,8 +1381,8 @@ def broker_config_log(name, key, value):
     | Broker Config Log | central | bam | trace |
 
     Returns: N/A
-        
-    """    
+
+    """
     if name == 'central':
         filename = "central-broker.json"
     elif name.startswith('module'):
@@ -1408,7 +1402,7 @@ def broker_config_log(name, key, value):
 
 def broker_config_flush_log(name, value):
     """
-    
+
     broker_config_flush_log 
 
     Flush broker configuration log.
@@ -1421,8 +1415,8 @@ def broker_config_flush_log(name, value):
     | Broker Config Flush Log | central | 1 |
 
     Returns: N/A
-        
-    """    
+
+    """
     if name == 'central':
         filename = "central-broker.json"
     elif name.startswith('module'):
@@ -1442,7 +1436,7 @@ def broker_config_flush_log(name, value):
 
 def broker_config_source_log(name, value):
     """
-    
+
     broker_config_source_log 
 
     Configure the log source.
@@ -1455,8 +1449,8 @@ def broker_config_source_log(name, value):
     | Broker Config Source Log | central | 1 |
 
     Returns: N/A
-        
-    """    
+
+    """
     if name == 'central':
         filename = "central-broker.json"
     elif name.startswith('module'):
@@ -1476,7 +1470,7 @@ def broker_config_source_log(name, value):
 
 def check_broker_stats_exist(name, key1, key2, timeout=TIMEOUT):
     """
-    
+
     check_broker_stats_exist 
 
     Return True if the stats key exists.
@@ -1493,8 +1487,8 @@ def check_broker_stats_exist(name, key1, key2, timeout=TIMEOUT):
     | Should Be True | ${exist} |
 
     Returns: N/A
-        
-    """    
+
+    """
     limit = time.time() + timeout
     while time.time() < limit:
         if name == 'central':
@@ -1522,7 +1516,7 @@ def check_broker_stats_exist(name, key1, key2, timeout=TIMEOUT):
 
 def get_broker_stats_size(name, key, timeout=TIMEOUT):
     """
-    
+
     get_broker_stats_size 
 
     Return the size of the stats key.
@@ -1536,8 +1530,8 @@ def get_broker_stats_size(name, key, timeout=TIMEOUT):
     | ${size} | Get Broker Stats Size | central | poller | # 2 |
 
     Returns: N/A
-        
-    """    
+
+    """
     limit = time.time() + timeout
     retval = 0
     while time.time() < limit:
@@ -1568,7 +1562,8 @@ def get_broker_stats_size(name, key, timeout=TIMEOUT):
         time.sleep(5)
     return retval
 
-def get_broker_stats(name: str, expected:str, timeout: int, *keys):
+
+def get_broker_stats(name: str, expected: str, timeout: int, *keys):
     """!
     read a value from broker stats
     @param name central, module or rrd
@@ -1581,7 +1576,7 @@ def get_broker_stats(name: str, expected:str, timeout: int, *keys):
     def json_get(json_dict, keys: tuple, index: int):
         try:
             key = keys[index]
-            if index == len(keys) -1:
+            if index == len(keys) - 1:
                 return json_dict[key]
             else:
                 return json_get(json_dict[key], keys, index + 1)
@@ -1618,7 +1613,7 @@ def json_get(json_dict, keys: tuple, index: int):
 
 def get_not_existing_indexes(count: int):
     """
-    
+
     get_not_existing_indexes
 
     Gets count indexes that does not exist in index_data.
@@ -1632,8 +1627,8 @@ def get_not_existing_indexes(count: int):
     | Log To Console | @{indexes} |
 
     Returns: a list of index ids.
-        
-    """    
+
+    """
     # Connect to the database
     connection = pymysql.connect(host=DB_HOST,
                                  user=DB_USER,
@@ -1666,7 +1661,7 @@ def get_not_existing_indexes(count: int):
 
 def get_indexes_to_delete(count: int):
     """
-    
+
     get_indexes_to_delete Gets count indexes from available ones.
 
     Return a list of indexes that does not exist in data_index.
@@ -1681,7 +1676,7 @@ def get_indexes_to_delete(count: int):
     Returns:
         LIST: a list of index ids.
 
-    """    
+    """
     files = [os.path.basename(x) for x in glob.glob(
         VAR_ROOT + "/lib/centreon/metrics/[0-9]*.rrd")]
     ids = [int(f.split(".")[0]) for f in files]
@@ -1725,7 +1720,7 @@ def delete_all_rrd_metrics():
 
 def check_rrd_info(metric_id: int, key: str, value, timeout: int = 60):
     """
-    
+
     check_rrd_info 
 
     Execute rrdtool info and check one value of the returned informations
@@ -1741,8 +1736,8 @@ def check_rrd_info(metric_id: int, key: str, value, timeout: int = 60):
     | Should Be True | ${result} |
 
     Returns: N/A
-        
-    """    
+
+    """
     limit = time.time() + timeout
     while time.time() < limit:
         res = getoutput(
@@ -1759,7 +1754,7 @@ def check_rrd_info(metric_id: int, key: str, value, timeout: int = 60):
 
 def get_metrics_for_service(service_id: int, metric_name: str = "%", timeout: int = 60):
     """
-    
+
     get_metrics_for_service 
 
     scan data base every 5s to extract metric ids for a service
@@ -1773,8 +1768,8 @@ def get_metrics_for_service(service_id: int, metric_name: str = "%", timeout: in
     | ${metrics} | Get Metrics For Service | 1 | % |
 
     Returns: N/A
-        
-    """    
+
+    """
     limit = time.time() + timeout
 
     select_request = f"SELECT metric_id FROM metrics JOIN index_data ON index_id=id WHERE service_id={service_id} and metric_name like '{metric_name}'"
@@ -1802,7 +1797,7 @@ def get_metrics_for_service(service_id: int, metric_name: str = "%", timeout: in
 
 def get_not_existing_metrics(count: int):
     """
-    
+
     get_not_existing_metrics 
 
     Return a list of metrics that does not exist.
@@ -1815,8 +1810,8 @@ def get_not_existing_metrics(count: int):
     | Log To Console | @{metrics} |
 
     Returns: N/A
-        
-    """    
+
+    """
     files = [os.path.basename(x) for x in glob.glob(
         VAR_ROOT + "/lib/centreon/metrics/[0-9]*.rrd")]
     ids = [int(f.split(".")[0]) for f in files]
@@ -1841,7 +1836,7 @@ def get_not_existing_metrics(count: int):
     index = 1
     retval = []
     while len(retval) < count:
-        if not index in inter:
+        if index not in inter:
             retval.append(index)
         index += 1
     return retval
@@ -2027,7 +2022,7 @@ def stop_map():
 
 def get_indexes_to_rebuild(count: int, nb_day=180):
     """
-    
+
     get_indexes_to_rebuild
 
     Get count indexes that are available to rebuild them.
@@ -2037,8 +2032,8 @@ def get_indexes_to_rebuild(count: int, nb_day=180):
         nb_day (int, optional): Defaults to 180.
 
     Returns: a list of indexes
-        
-    """    
+
+    """
     files = [os.path.basename(x) for x in glob.glob(
         VAR_ROOT + "/lib/centreon/metrics/[0-9]*.rrd")]
     ids = [int(f.split(".")[0]) for f in files]
@@ -2086,7 +2081,7 @@ def get_indexes_to_rebuild(count: int, nb_day=180):
 
 def add_duplicate_metrics():
     """
-    
+
     add_duplicate_metrics
 
     add a value at the mid of the first day of each metric
@@ -2094,7 +2089,7 @@ def add_duplicate_metrics():
     Returns:
         list : a list of indexes of pair <time of oldest value>, <metric id>
 
-    """    
+    """
     connection = pymysql.connect(host=DB_HOST,
                                  user=DB_USER,
                                  password=DB_PASS,
@@ -2120,7 +2115,7 @@ def add_duplicate_metrics():
 
 def check_for_NaN_metric(add_duplicate_metrics_ret):
     """
-    
+
     check_for_NaN_metric 
 
     check that metrics are not a NaN during one day
@@ -2131,7 +2126,7 @@ def check_for_NaN_metric(add_duplicate_metrics_ret):
     Returns:
         boolean : true or false
 
-    """    
+    """
     for min_timestamp, metric_id in add_duplicate_metrics_ret:
         max_timestamp = min_timestamp + 86400
         res = getoutput(
@@ -2151,7 +2146,7 @@ def check_for_NaN_metric(add_duplicate_metrics_ret):
 
 def get_metrics_matching_indexes(indexes):
     """
-    
+
     get_metrics_matching_indexes 
 
     Returns metric ids matching the given indexes.
@@ -2162,7 +2157,7 @@ def get_metrics_matching_indexes(indexes):
     Returns:
         list : a list of metric ids.
 
-    """    
+    """
     # Connect to the database
     connection = pymysql.connect(host=DB_HOST,
                                  user=DB_USER,
@@ -2183,7 +2178,7 @@ def get_metrics_matching_indexes(indexes):
 
 def remove_graphs(port, indexes, metrics, timeout=10):
     """
-    
+
     remove_graphs 
 
     send a gRPC command to remove graphs (by indexes or by metrics)
@@ -2194,7 +2189,7 @@ def remove_graphs(port, indexes, metrics, timeout=10):
         metrics (str): metrics a list of metrics
         timeout (int, optional): Defaults to 10.
 
-    """    
+    """
     limit = time.time() + timeout
     while time.time() < limit:
         time.sleep(1)
@@ -2255,7 +2250,7 @@ def broker_get_sql_manager_stats(port: int, query, timeout=TIMEOUT):
 
 def remove_graphs_from_db(indexes, metrics, timeout=10):
     """
-    
+
     remove_graphs_from_db 
 
     send a query to the db to remove graphs (by indexes or by metrics)
@@ -2265,7 +2260,7 @@ def remove_graphs_from_db(indexes, metrics, timeout=10):
         metrics (list): a list of metrics
         timeout (int, optional): Defaults to 10.
 
-    """    
+    """
     logger.console("rem1")
     connection = pymysql.connect(host=DB_HOST,
                                  user=DB_USER,
@@ -2274,7 +2269,6 @@ def remove_graphs_from_db(indexes, metrics, timeout=10):
                                  charset='utf8mb4',
                                  cursorclass=pymysql.cursors.DictCursor)
 
-    ids_db = []
     with connection:
         with connection.cursor() as cursor:
             if len(indexes) > 0:
@@ -2294,7 +2288,7 @@ def remove_graphs_from_db(indexes, metrics, timeout=10):
 
 def rebuild_rrd_graphs(port, indexes, timeout: int = TIMEOUT):
     """
-    
+
     rebuild_rrd_graphs 
 
     Execute the gRPC command RebuildRRDGraphs()
@@ -2304,7 +2298,7 @@ def rebuild_rrd_graphs(port, indexes, timeout: int = TIMEOUT):
         indexes (list): The list of indexes corresponding to metrics to rebuild.
         timeout (int, optional): Defaults to TIMEOUT.
 
-    """    
+    """
     logger.console("start gRPC server")
     limit = time.time() + timeout
     while time.time() < limit:
@@ -2312,7 +2306,6 @@ def rebuild_rrd_graphs(port, indexes, timeout: int = TIMEOUT):
         time.sleep(1)
         with grpc.insecure_channel("127.0.0.1:{}".format(port)) as channel:
             stub = broker_pb2_grpc.BrokerStub(channel)
-            k = 0.0
             idx = broker_pb2.IndexIds()
             idx.index_ids.extend(indexes)
             try:
@@ -2324,15 +2317,14 @@ def rebuild_rrd_graphs(port, indexes, timeout: int = TIMEOUT):
 
 def rebuild_rrd_graphs_from_db(indexes):
     """
-    
-    rebuild_rrd_graphs_from_db 
+    rebuild_rrd_graphs_from_db
 
     Send a query to the db to rebuild graphs
 
     Args:
         indexes (list): The list of indexes corresponding to metrics to rebuild.
 
-    """    
+    """
     connection = pymysql.connect(host=DB_HOST,
                                  user=DB_USER,
                                  password=DB_PASS,
@@ -2340,7 +2332,6 @@ def rebuild_rrd_graphs_from_db(indexes):
                                  charset='utf8mb4',
                                  cursorclass=pymysql.cursors.DictCursor)
 
-    ids_db = []
     with connection:
         with connection.cursor() as cursor:
             if len(indexes) > 0:
@@ -2353,7 +2344,7 @@ def rebuild_rrd_graphs_from_db(indexes):
 
 def compare_rrd_average_value(metric, value: float):
     """
-    
+
     compare_rrd_average_value 
 
     Compare the average value for an RRD metric on the last 30 days with a value.
@@ -2363,10 +2354,10 @@ def compare_rrd_average_value(metric, value: float):
         value (float): float The value to compare with.
 
     Returns: A boolean.
-        
+
     """
-    res = getoutput(f"rrdtool graph dummy --start=end-180d --end=now"
-                    " DEF:x={VAR_ROOT}/lib/centreon/metrics/{metric}.rrd:value:AVERAGE VDEF:xa=x,AVERAGE PRINT:xa:%lf")
+    res = getoutput(
+        f"rrdtool graph dummy --start=end-180d --end=now DEF:x={VAR_ROOT}/lib/centreon/metrics/{metric}.rrd:value:AVERAGE VDEF:xa=x,AVERAGE PRINT:xa:%lf")
     lst = res.split('\n')
     if len(lst) >= 2:
         res = float(lst[1].replace(',', '.'))
@@ -2386,9 +2377,8 @@ def compare_rrd_status_average_value(index_id, value: int):
         index_id is the index of the status
         average value expected is 100 if value=0, 75 if value=1, 0 if value=2
     """
-    res = getoutput(f"rrdtool graph dummy --start=end-180d --end=now"
-                    " DEF:x=" + VAR_ROOT +
-                    "/lib/centreon/status/{index_id}.rrd:value:AVERAGE VDEF:xa=x,AVERAGE PRINT:xa:%lf")
+    res = getoutput(
+        f"rrdtool graph dummy --start=end-180d --end=now DEF:x={VAR_ROOT}/lib/centreon/status/{index_id}.rrd:value:AVERAGE VDEF:xa=x,AVERAGE PRINT:xa:%lf")
     lst = res.split('\n')
     if len(lst) >= 2:
         res = float(lst[1].replace(',', '.'))
@@ -2412,9 +2402,9 @@ def compare_rrd_average_value_with_grpc(metric, key, value: float):
     )
     lst = res.split('\n')
     if len(lst) >= 2:
-        for l in lst:
-            if key in l:
-                last_update = int(l.split('=')[1])
+        for line in lst:
+            if key in line:
+                last_update = int(line.split('=')[1])
                 logger.console(f"{key}: {last_update}")
                 return last_update == value*60
     else:
@@ -2454,7 +2444,7 @@ def check_sql_connections_count_with_grpc(port, count, timeout=TIMEOUT):
 
 def check_all_sql_connections_down_with_grpc(port, timeout=TIMEOUT):
     """
-    
+
     check_all_sql_connections_down_with_grpc
 
     Call the GetSqlManagerStats function by gRPC and checks there are count active connections.
@@ -2464,8 +2454,8 @@ def check_all_sql_connections_down_with_grpc(port, timeout=TIMEOUT):
         timeout (int, optional): Defaults to TIMEOUT.
 
     Returns: A boolean.
-        
-    """    
+
+    """
     limit = time.time() + timeout
     while time.time() < limit:
         time.sleep(1)
@@ -2484,7 +2474,7 @@ def check_all_sql_connections_down_with_grpc(port, timeout=TIMEOUT):
 
 def add_bam_config_to_broker(name):
     """
-    
+
     add_bam_config_to_broker 
 
     Add the bam configuration to broker.
@@ -2492,7 +2482,7 @@ def add_bam_config_to_broker(name):
     Args:
         name (str): The broker name to consider.
 
-    """    
+    """
     if name == 'central':
         filename = "central-broker.json"
     elif name.startswith('module'):
@@ -2544,7 +2534,7 @@ def add_bam_config_to_broker(name):
 
 def remove_poller(port, name, timeout=TIMEOUT):
     """
-    
+
     remove_poller 
 
     send a gRPC command to remove by name a poller
@@ -2554,7 +2544,7 @@ def remove_poller(port, name, timeout=TIMEOUT):
         name (str): the poller name
         timeout (int, optional): Defaults to TIMEOUT.
 
-    """    
+    """
     limit = time.time() + timeout
     while time.time() < limit:
         logger.console(f"Try to call removePoller by name on port {port}")
@@ -2572,7 +2562,7 @@ def remove_poller(port, name, timeout=TIMEOUT):
 
 def remove_poller_by_id(port, idx, timeout=TIMEOUT):
     """
-    
+
     remove_poller_by_id 
 
     send a gRPC command to remove by id a poller
@@ -2582,7 +2572,7 @@ def remove_poller_by_id(port, idx, timeout=TIMEOUT):
         idx (int): the poller name
         timeout (int, optional): Defaults to TIMEOUT.
 
-    """    
+    """
     limit = time.time() + timeout
     while time.time() < limit:
         logger.console(
@@ -2689,7 +2679,7 @@ def set_broker_log_level(port, name, log, level, timeout=TIMEOUT):
 
 def get_broker_process_stat(port, timeout=10):
     """
-    
+
     get_broker_process_stat 
 
     Call the GetGenericStats function by gRPC it works with both engine and broker
@@ -2703,8 +2693,8 @@ def get_broker_process_stat(port, timeout=10):
     | ${process_stat_pb2} = | Get Engine Process Stat | 8082 |
 
     Returns: process__stat__pb2.pb_process_stat
-        
-    """    
+
+    """
     limit = time.time() + timeout
     while time.time() < limit:
         time.sleep(1)
@@ -2723,6 +2713,7 @@ def get_broker_process_stat(port, timeout=10):
 def parse_victoria_body(request_body: str):
     victoria_payload = {}
     for field_val in request_body.split(','):
+        key_val = ""
         if field_val == "status" or field_val == "metric":
             victoria_payload["type"] = field_val
         elif " " in field_val:
@@ -2740,7 +2731,7 @@ def parse_victoria_body(request_body: str):
 
 def check_victoria_data(request_body: str, data_type: str, min_timestamp: int,  **to_check):
     """
-    
+
     check_victoria_data 
 
     Return the value of a check if the data is present in the request body and if it matches the given values.
@@ -2753,8 +2744,8 @@ def check_victoria_data(request_body: str, data_type: str, min_timestamp: int,
     Example:
     | ${metric_found} = | Check Victoria Data | ${body} | metric | 16000000 | unit=% | host_id=16 | serv_id=314 |
     | Should Be True | ${metric_found} | if the request body contains a metric with the unit=%, host_id=16 and serv_id=314 |
-  
-    """    
+
+    """
     for line in request_body.splitlines():
         datas = parse_victoria_body(line)
         if datas["type"] != data_type:
@@ -2772,7 +2763,7 @@ def check_victoria_data(request_body: str, data_type: str, min_timestamp: int,
 
 def check_victoria_metric(request_body: str, min_timestamp: int,  **to_check):
     """
-    
+
     check_victoria_metric 
 
     Return the value of a check if the metric is present in the request body and if it matches the given values.
@@ -2787,14 +2778,14 @@ def check_victoria_metric(request_body: str, min_timestamp: int,  **to_check):
     | ${metric_found} = TRUE if the request body contains a metric with the unit=%, host_id=16 and serv_id=314
 
     Returns: N/A
-        
-    """      
+
+    """
     return check_victoria_data(request_body, "metric", min_timestamp, **to_check)
 
 
 def check_victoria_status(request_body: str, min_timestamp: int,  **to_check):
     """
-    
+
     check_victoria_status 
 
     Return the value of a check if the status is present in the request body and if it matches the given values.
@@ -2809,7 +2800,7 @@ def check_victoria_status(request_body: str, min_timestamp: int,  **to_check):
     | ${metric_found} = TRUE if the request body contains a status with the host_id=16 and serv_id=314
 
     Returns: N/A
-        
+
     """
     return check_victoria_data(request_body, "status", min_timestamp, **to_check)
 
diff --git a/tests/resources/Engine.py b/tests/resources/Engine.py
index d80fb16f3da..b16c4efc7cf 100755
--- a/tests/resources/Engine.py
+++ b/tests/resources/Engine.py
@@ -8,7 +8,6 @@
 from array import array
 from os import makedirs, chmod
 from os.path import exists, dirname
-from xml.etree.ElementTree import Comment
 from robot.api import logger
 from robot.libraries.BuiltIn import BuiltIn
 import db_conf
@@ -61,7 +60,7 @@ def _create_centengine(self, id: int, debug_level=0):
         Args:
             id (int): id
             debug_level (int, optional): Defaults to 0.
-        """        
+        """
         grpc_port = id + 50001
         return ("cfg_file={2}/config{0}/hosts.cfg\n"
                 "cfg_file={2}/config{0}/services.cfg\n"
@@ -229,7 +228,7 @@ def create_anomaly_detection(self, host_id: int, dependent_service_id: int, metr
         return retval
 
     def create_bam_timeperiod(self):
-        """create_bam_timeperiod 
+        """create_bam_timeperiod
 
         Create the timeperiod for the BAM module
 
@@ -474,7 +473,6 @@ def build_configs(self, hosts: int, services_by_host: int, debug_level=0):
         if hosts % self.instances > 0:
             r = 1
         v = int(hosts / self.instances) + r
-        last = hosts - (self.instances - 1) * v
         for inst in range(self.instances):
             if v < hosts:
                 nb_hosts = v
@@ -498,7 +496,7 @@ def build_configs(self, hosts: int, services_by_host: int, debug_level=0):
                 self.hosts.append("host_{}".format(h["hid"]))
                 for j in range(1, services_by_host + 1):
                     ff.write(self._create_service(h["hid"],
-                                                 (inst * self.commands_count + 1, (inst + 1) * self.commands_count)))
+                                                  (inst * self.commands_count + 1, (inst + 1) * self.commands_count)))
                     self.services.append("service_{}".format(h["hid"]))
             ff.close()
             f.close()
@@ -530,7 +528,7 @@ def build_configs(self, hosts: int, services_by_host: int, debug_level=0):
 
 define connector {
     connector_name                 SSH Connector
-    connector_line                 /usr/lib64/centreon-connector/centreon_connector_ssh --debug --log-file=/tmp/var/log/centreon-engine/config0/connector_ssh.log 
+    connector_line                 /usr/lib64/centreon-connector/centreon_connector_ssh --debug --log-file=/tmp/var/log/centreon-engine/config0/connector_ssh.log
 }
 """)
             f.close()
@@ -623,7 +621,7 @@ def build_configs(self, hosts: int, services_by_host: int, debug_level=0):
     host_notifications_enabled     1
     service_notifications_enabled  1
     service_notification_commands              command_notif
-    host_notification_commands              command_notif    
+    host_notification_commands              command_notif
 }
 define contact {
     contact_name                   U3
@@ -706,10 +704,9 @@ def centengine_conf_add_anomaly(self):
 engine = None
 
 
-
 def config_engine(num: int, hosts: int = 50, srv_by_host: int = 20):
     """
-    config_engine 
+    config_engine
 
     Configure all the necessary files for num instances of centengine.
 
@@ -717,10 +714,11 @@ def config_engine(num: int, hosts: int = 50, srv_by_host: int = 20):
         num (int): How many engine configurations to start
         hosts (int, optional): Defaults to 50.
         srv_by_host (int, optional): Defaults to 20.
-    """    
+    """
     global engine
     engine = EngineInstance(num, hosts, srv_by_host)
 
+
 def get_engines_count():
     """get_engines_count _summary_
 
@@ -734,10 +732,11 @@ def get_engines_count():
     else:
         return engine.instances
 
+
 def engine_config_set_value(idx: int, key: str, value: str, force: bool = False):
     """
-    engine_config_set_value 
-    
+    engine_config_set_value
+
     Run a command to set a value in the centengine.cfg for the config idx
 
     Args:
@@ -745,7 +744,7 @@ def engine_config_set_value(idx: int, key: str, value: str, force: bool = False)
         key (str): the key to change the value.
         value (str): the new value to set to the key variable.
         force (bool, optional): Defaults to False.
-    """    
+    """
     filename = f"{ETC_ROOT}/centreon-engine/config{idx}/centengine.cfg"
     f = open(filename, "r")
     lines = f.readlines()
@@ -764,6 +763,7 @@ def engine_config_set_value(idx: int, key: str, value: str, force: bool = False)
     f.writelines(lines)
     f.close()
 
+
 def engine_config_add_value(idx: int, key: str, value: str):
     """
     engine_config_add_value _Engine Config Add Value_
@@ -774,12 +774,13 @@ def engine_config_add_value(idx: int, key: str, value: str):
         idx (int): idx index of the configuration (from 0)
         key (str): the key to change the value.
         value (str): the new value to set to the key variable.
-    """ 
+    """
     filename = f"{ETC_ROOT}/centreon-engine/config{idx}/centengine.cfg"
     f = open(filename, "a")
     f.write(f"{key}={value}")
     f.close()
 
+
 def engine_config_set_value_in_services(idx: int, desc: str, key: str, value: str):
     """
     engine_config_set_value_in_services _Engine Config Set Value In Services_
@@ -812,7 +813,7 @@ def engine_config_set_value_in_services(idx: int, desc: str, key: str, value: st
 
 def engine_config_replace_value_in_services(idx: int, desc: str, key: str, value: str):
     """
-    engine_config_replace_value_in_services 
+    engine_config_replace_value_in_services
 
     Function to update a value in the services.cfg for the config idx
     Args:
@@ -822,7 +823,7 @@ def engine_config_replace_value_in_services(idx: int, desc: str, key: str, value
         value (str): value the new value to set to the key variable.
 
     Returns: N/A
-    """    
+    """
     filename = f"{ETC_ROOT}/centreon-engine/config{idx}/services.cfg"
     with open(filename, "r") as f:
         lines = f.readlines()
@@ -839,9 +840,10 @@ def engine_config_replace_value_in_services(idx: int, desc: str, key: str, value
     with open(filename, "w") as f:
         f.writelines(lines)
 
+
 def engine_config_set_value_in_hosts(idx: int, desc: str, key: str, value: str):
     """
-    engine_config_set_value_in_hosts 
+    engine_config_set_value_in_hosts
 
     Function to set a value in the hosts.cfg for the config idx.
 
@@ -867,9 +869,10 @@ def engine_config_set_value_in_hosts(idx: int, desc: str, key: str, value: str):
     f.writelines(lines)
     f.close()
 
+
 def engine_config_replace_value_in_hosts(idx: int, desc: str, key: str, value: str):
     """
-    engine_config_replace_value_in_hosts 
+    engine_config_replace_value_in_hosts
 
     Function to change a value in the hosts.cfg for the config idx.
 
@@ -880,7 +883,7 @@ def engine_config_replace_value_in_hosts(idx: int, desc: str, key: str, value: s
         value (str): the new value to set to the key variable.
 
     Returns: N/A
-    """    
+    """
     filename = ETC_ROOT + "/centreon-engine/config{}/hosts.cfg".format(idx)
     f = open(filename, "r")
     lines = f.readlines()
@@ -900,9 +903,10 @@ def engine_config_replace_value_in_hosts(idx: int, desc: str, key: str, value: s
     f.writelines(lines)
     f.close()
 
+
 def engine_config_change_command(idx: int, command_index: str, new_command: str):
     """
-    engine_config_change_command 
+    engine_config_change_command
 
     Function to change a value in the commands.cfg for the config idx.
 
@@ -910,7 +914,7 @@ def engine_config_change_command(idx: int, command_index: str, new_command: str)
         idx (int): index of the configuration (from 0)
         command_index (str): ndex of the command (may be a regex)
         new_command (str): new_command
-    """    
+    """
     f = open(f"{CONF_DIR}/config{idx}/commands.cfg", "r")
     lines = f.readlines()
     f.close
@@ -930,9 +934,10 @@ def engine_config_change_command(idx: int, command_index: str, new_command: str)
     f.writelines(new_lines)
     f.close
 
+
 def engine_config_add_command(idx: int, command_name: str, new_command: str, connector: str = None):
     """
-    engine_config_add_command 
+    engine_config_add_command
 
     Function to add a new command in the commands.cfg for the config idx
 
@@ -944,23 +949,24 @@ def engine_config_add_command(idx: int, command_name: str, new_command: str, con
 
     Returns: N/A
 
-    """    
+    """
     f = open(f"{CONF_DIR}/config{idx}/commands.cfg", "a")
     if connector is None:
         f.write("""define command {{
-    command_name                   {} 
+    command_name                   {}
     command_line                   {}
 }}
     """.format(command_name, new_command))
     else:
         f.write("""define command {{
-    command_name                   {} 
+    command_name                   {}
     command_line                   {}
     connector                      {}
 }}
     """.format(command_name, new_command, connector))
     f.close()
 
+
 def engine_config_set_value_in_contacts(idx: int, desc: str, key: str, value: str):
     """
     engine_config_set_value_in_contacts _Engine Config Set Value In Contacts_
@@ -991,6 +997,7 @@ def engine_config_set_value_in_contacts(idx: int, desc: str, key: str, value: st
     f.writelines(lines)
     f.close()
 
+
 def engine_config_set_value_in_escalations(idx: int, desc: str, key: str, value: str):
     """
     engine_config_set_value_in_escalations _Engine Config Set Value In Escalations_
@@ -1002,7 +1009,7 @@ def engine_config_set_value_in_escalations(idx: int, desc: str, key: str, value:
         desc (str): escalations_name
         key (str): the key to change the value.
         value (str): the new value to set to the key variable.
-    """    
+    """
     with open(f"{ETC_ROOT}/centreon-engine/config{idx}/escalations.cfg", "r") as ff:
         lines = ff.readlines()
     r = re.compile(r"^\s*;escalation_name\s+" + desc + "\s*$")
@@ -1056,6 +1063,7 @@ def engine_config_remove_service_host(idx: int, host: str):
     f.writelines(lines)
     f.close()
 
+
 def engine_config_remove_host(idx: int, host: str):
     """
     engine_config_remove_host _Engine Config Remove Host_
@@ -1098,6 +1106,7 @@ def engine_config_remove_host(idx: int, host: str):
     f.writelines(lines)
     f.close()
 
+
 def add_host_group(index: int, id_host_group: int, members: list):
     """
     add_host_group _Add Host Group_
@@ -1106,17 +1115,17 @@ def add_host_group(index: int, id_host_group: int, members: list):
 
     Args:
         index (int): index of the configuration (from 0)
-        id_host_group (int): 
-        members (list): 
+        id_host_group (int):
+        members (list):
 
     Returns: N/A
 
     """
-    mbs = [l for l in members if l in engine.hosts]
-    f = open(ETC_ROOT + "/centreon-engine/config{}/hostgroups.cfg".format(index), "a+")
-    logger.console(mbs)
-    f.write(engine.create_host_group(id_host_group, mbs))
-    f.close()
+    mbs = [line for line in members if line in engine.hosts]
+    with open(f"{ETC_ROOT}/centreon-engine/config{index}/hostgroups.cfg", "a+") as f:
+        logger.console(mbs)
+        f.write(engine.create_host_group(id_host_group, mbs))
+
 
 def rename_host_group(index: int, id_host_group: int, name: str, members: list):
     """
@@ -1126,24 +1135,24 @@ def rename_host_group(index: int, id_host_group: int, name: str, members: list):
 
     Args:
         index (int): index of the configuration (from 0)
-        id_host_group (int): 
+        id_host_group (int):
         name (str): host_group_name
         members (list): _description_
 
     Returns: N/A
-
     """
-    mbs = [l for l in members if l in engine.hosts]
-    f = open(ETC_ROOT + "/centreon-engine/config{}/hostgroups.cfg".format(index), "w")
-    logger.console(mbs)
-    f.write("""define hostgroup {{
-    hostgroup_id                    {0}
-    hostgroup_name                  hostgroup_{1}
-    alias                           hostgroup_{1}
-    members                         {2}
-}}
-""".format(id_host_group, name, ",".join(mbs)))
-    f.close()
+    mbs = [line for line in members if line in engine.hosts]
+    mbs_str = ",".join(mbs)
+    with open(f"{ETC_ROOT}/centreon-engine/config{index}/hostgroups.cfg", "w") as f:
+        logger.console(mbs)
+        f.write(f"""define hostgroup {{
+        hostgroup_id                    {id_host_group}
+        hostgroup_name                  hostgroup_{name}
+        alias                           hostgroup_{name}
+        members                         {mbs_str}
+    }}
+""")
+
 
 def rename_service(index: int, hst: str, svc: str, new_svc: str):
     """
@@ -1173,30 +1182,30 @@ def rename_service(index: int, hst: str, svc: str, new_svc: str):
     l_svc = None
 
     for i in range(len(ll)):
-        l = ll[i]
+        line = ll[i]
         if inside:
-            if rs_end.match(l):
+            if rs_end.match(line):
                 inside = False
                 if svc == my_svc and hst == my_hst:
                     ll[l_svc] = f"    service_description\t{new_svc}\n"
                 svc, hst, l_svc = None, None, None
                 continue
-            m = rs_hst.search(l)
+            m = rs_hst.search(line)
             if m:
                 my_hst = m.group(1)
             else:
-                m = rs_svc.search(l)
+                m = rs_svc.search(line)
                 if m:
                     my_svc = m.group(1)
                     l_svc = i
 
         else:
-            if rs_start.match(l):
+            if rs_start.match(line):
                 inside = True
 
-    f = open(f"{ETC_ROOT}/centreon-engine/config{index}/services.cfg", "w")
-    f.writelines(ll)
-    f.close()
+    with open(f"{ETC_ROOT}/centreon-engine/config{index}/services.cfg", "w") as f:
+        f.writelines(ll)
+
 
 def add_service_group(index: int, id_service_group: int, members: list):
     """
@@ -1206,12 +1215,12 @@ def add_service_group(index: int, id_service_group: int, members: list):
 
     Args:
         index (int): index of the configuration (from 0)
-        id_service_group (int): 
-        members (list): 
+        id_service_group (int):
+        members (list):
 
     Returns: N/A
 
-    """    
+    """
     f = open(
         ETC_ROOT + "/centreon-engine/config{}/servicegroups.cfg".format(index), "a+")
     logger.console(members)
@@ -1228,15 +1237,17 @@ def rename_service_group(index: int, old_servicegroup_name: str, new_service_gro
     """
     with open(f"{ETC_ROOT}/centreon-engine/config{index}/servicegroups.cfg", "r") as f:
         ll = f.readlines()
-    group_name_search = re.compile(fr"^\s+servicegroup_name\s+{old_servicegroup_name}$")
+    group_name_search = re.compile(
+        fr"^\s+servicegroup_name\s+{old_servicegroup_name}$")
     for i in range(len(ll)):
-        l = ll[i]
-        if group_name_search.match(l):
+        line = ll[i]
+        if group_name_search.match(line):
             ll[i] = f"    servicegroup_name                  {new_service_group_name}\n"
             break
     with open(f"{ETC_ROOT}/centreon-engine/config{index}/servicegroups.cfg", "w") as f:
         f.writelines(ll)
 
+
 def add_contact_group(index: int, id_contact_group: int, members: list):
     """
     add_contact_group _Add Contact Group_
@@ -1250,7 +1261,7 @@ def add_contact_group(index: int, id_contact_group: int, members: list):
 
     Returns: N/A
 
-    """ 
+    """
     with open(f"{ETC_ROOT}/centreon-engine/config{index}/contactgroups.cfg", "a+") as f:
         logger.console(members)
         f.write(engine.create_contact_group(id_contact_group, members))
@@ -1274,21 +1285,21 @@ def create_service(index: int, host_id: int, cmd_id: int):
     Returns: N/A
 
     """
-    f = open(ETC_ROOT + "/centreon-engine/config{}/services.cfg".format(index), "a+")
-    svc = engine._create_service(host_id, [1, cmd_id])
-    lst = svc.split('\n')
-    good = [l for l in lst if "_SERVICE_ID" in l][0]
-    m = re.search(r"_SERVICE_ID\s+([^\s]*)$", good)
-    if m is not None:
-        retval = int(m.group(1))
-    else:
-        raise Exception(
-            "Impossible to get the service id from '{}'".format(good))
-        m = 0
-    f.write(svc)
-    f.close()
+    with open(f"{ETC_ROOT}/centreon-engine/config{index}/services.cfg", "a+") as f:
+        svc = engine._create_service(host_id, [1, cmd_id])
+        lst = svc.split('\n')
+        good = [line for line in lst if "_SERVICE_ID" in line][0]
+        m = re.search(r"_SERVICE_ID\s+([^\s]*)$", good)
+        if m is not None:
+            retval = int(m.group(1))
+        else:
+            raise Exception(
+                "Impossible to get the service id from '{}'".format(good))
+            m = 0
+        f.write(svc)
     return retval
 
+
 def create_anomaly_detection(index: int, host_id: int, dependent_service_id: int, metric_name: string, sensitivity: float = 0.0):
     """
     create_anomaly_detection _Create Anomaly Detection_
@@ -1310,7 +1321,7 @@ def create_anomaly_detection(index: int, host_id: int, dependent_service_id: int
     to_append = engine.create_anomaly_detection(
         host_id, dependent_service_id, metric_name, sensitivity)
     lst = to_append.split('\n')
-    good = [l for l in lst if "service_id" in l][0]
+    good = [line for line in lst if "service_id" in line][0]
     m = re.search(r"service_id\s+([^\s]*)$", good)
     if m is not None:
         retval = int(m.group(1))
@@ -1323,6 +1334,7 @@ def create_anomaly_detection(index: int, host_id: int, dependent_service_id: int
     engine.centengine_conf_add_anomaly()
     return retval
 
+
 def engine_log_duplicate(result: list):
     """
     engine_log_duplicate _Engine Log Duplicate_
@@ -1334,41 +1346,44 @@ def engine_log_duplicate(result: list):
 
     Returns: N/A
 
-    """    
+    """
     dup = True
     for i in result:
         if (i[0] % 2) != 0:
             dup = False
     return dup
 
+
 def clone_engine_config_to_db():
     """
-    clone_engine_config_to_db 
+    clone_engine_config_to_db
 
     Clone the engine configuration to the database
 
     Returns: N/A
 
-    """    
+    """
     global dbconf
     dbconf = db_conf.DbConf(engine)
     dbconf.create_conf_db()
 
+
 def add_bam_config_to_engine():
     """
-    add_bam_config_to_engine 
+    add_bam_config_to_engine
 
     Add the bam configuration to the engine
 
     Returns:
 
-    """    
+    """
     global dbconf
     dbconf.init_bam()
 
+
 def create_ba_with_services(name: str, typ: str, svc: list, dt_policy="inherit"):
     """
-    create_ba_with_services 
+    create_ba_with_services
 
     Create a BA with the given services
 
@@ -1379,14 +1394,15 @@ def create_ba_with_services(name: str, typ: str, svc: list, dt_policy="inherit")
         dt_policy (str, optional): Defaults to "inherit".
 
     Returns: N/A
-        
+
     """
     global dbconf
     return dbconf.create_ba_with_services(name, typ, svc, dt_policy)
 
+
 def create_ba(name: str, typ: str, critical_impact: int, warning_impact: int, dt_policy="inherit"):
     """
-    create_ba 
+    create_ba
 
     Args:
         name (str): ba name
@@ -1396,83 +1412,88 @@ def create_ba(name: str, typ: str, critical_impact: int, warning_impact: int, dt
         dt_policy (str, optional): Defaults to "inherit".
 
     Returns: N/A
-   
-    """    
+
+    """
     global dbconf
     return dbconf.create_ba(name, typ, critical_impact, warning_impact, dt_policy)
 
+
 def add_boolean_kpi(id_ba: int, expression: str, impact_if: bool, critical_impact: int):
     """
-    add_boolean_kpi 
+    add_boolean_kpi
 
     Add a boolean KPI to a BA
 
     Args:
-        id_ba (int): 
-        expression (str): 
+        id_ba (int):
+        expression (str):
         impact_if (bool): (true/false)
         critical_impact (int): Impact weight in the event of a Critical condition, in real-time monitoring
 
     Returns: N/A
-      
-    """    
+
+    """
     return dbconf.add_boolean_kpi(id_ba, expression, impact_if, critical_impact)
 
+
 def update_boolean_rule(boolean_id: int, expression: str):
     """
-    update_boolean_rule 
+    update_boolean_rule
 
     Udpate a boolean rule
 
     Args:
-        boolean_id (int): 
-        expression (str): 
+        boolean_id (int):
+        expression (str):
 
     Returns:
         _type_: _description_
-    """    
+    """
     dbconf.update_boolean_rule(boolean_id, expression)
 
+
 def add_ba_kpi(id_ba_src: int, id_ba_dest: int, critical_impact: int, warning_impact: int, unknown_impact: int):
     """
-    add_ba_kpi 
+    add_ba_kpi
 
     Add a BA KPI
 
     Args:
-        id_ba_src (int): 
-        id_ba_dest (int): 
+        id_ba_src (int):
+        id_ba_dest (int):
         critical_impact (int): Impact weight in the event of a Critical condition, in real-time monitoring
         warning_impact (int): Impact weight in the event of a Warning condition, in real-time monitoring. Ignored if indicator is a boolean rule
         unknown_impact (int): _Impact weight in the event of an Unknown condition, in real-time monitoring. Ignored if indicator is a boolean rule
 
     Returns: N/A
- 
-    """    
+
+    """
     dbconf.add_ba_kpi(id_ba_src, id_ba_dest, critical_impact,
                       warning_impact, unknown_impact)
 
+
 def add_service_kpi(host: str, serv: str, id_ba: int, critical_impact: int, warning_impact: int, unknown_impact: int):
     """
-    add_service_kpi 
+    add_service_kpi
 
     Add a service KPI
 
     Args:
-        host (str): 
-        serv (str): 
-        id_ba (int): 
+        host (str):
+        serv (str):
+        id_ba (int):
         critical_impact (int): Impact weight in the event of a Critical condition, in real-time monitoring
         warning_impact (int): Impact weight in the event of a Warning condition, in real-time monitoring. Ignored if indicator is a boolean rule
         unknown_impact (int): _Impact weight in the event of an Unknown condition, in real-time monitoring. Ignored if indicator is a boolean rule
 
     Returns: N/A
-        
-    """    
+
+    """
     global dbconf
     dbconf.add_service_kpi(
         host, serv, id_ba, critical_impact, warning_impact, unknown_impact)
 
+
 def get_command_id(service: int):
     """
     get_command_id _summary_
@@ -1483,13 +1504,14 @@ def get_command_id(service: int):
         service (int): id of the service linked to the command
 
     Returns: N/A
-        
-    """    
+
+    """
     global engine
     global dbconf
     cmd_name = engine.service_cmd[service]
     return dbconf.command[cmd_name]
 
+
 def get_command_service_param(service: int):
     """
     get_command_service_param _summary_
@@ -1500,26 +1522,27 @@ def get_command_service_param(service: int):
         service (int): id of the service linked to the command
 
     Returns: N/A
-      
-    """    
+
+    """
     global engine
     return engine.service_cmd[service][8:]
 
+
 def change_normal_svc_check_interval(use_grpc: int, hst: str, svc: str, check_interval: int):
     """
-    change_normal_svc_check_interval 
+    change_normal_svc_check_interval
 
     Update the normal check interval for a service
 
     Args:
-        use_grpc (int): 
-        hst (str): 
-        svc (str): 
-        check_interval (int): 
+        use_grpc (int):
+        hst (str):
+        svc (str):
+        check_interval (int):
 
     Returns: N/A
- 
-    """    
+
+    """
     if use_grpc > 0:
         with grpc.insecure_channel("127.0.0.1:50001") as channel:
             stub = engine_pb2_grpc.EngineStub(channel)
@@ -1533,19 +1556,20 @@ def change_normal_svc_check_interval(use_grpc: int, hst: str, svc: str, check_in
         f.write(cmd)
         f.close()
 
+
 def change_normal_host_check_interval(use_grpc: int, hst: str, check_interval: int):
     """change_normal_host_check_interval _summary_
 
     Update the normal check interval for a host
 
     Args:
-        use_grpc (int): 
-        hst (str): 
-        check_interval (int): 
+        use_grpc (int):
+        hst (str):
+        check_interval (int):
 
     Returns: N/A
-        
-    """  
+
+    """
     if use_grpc > 0:
         with grpc.insecure_channel("127.0.0.1:50001") as channel:
             stub = engine_pb2_grpc.EngineStub(channel)
@@ -1558,21 +1582,22 @@ def change_normal_host_check_interval(use_grpc: int, hst: str, check_interval: i
         f.write(cmd)
         f.close()
 
+
 def change_retry_svc_check_interval(use_grpc: int, hst: str, svc: str, retry_interval: int):
     """
-    change_retry_svc_check_interval 
+    change_retry_svc_check_interval
 
     Update the retry check interval for a service
 
     Args:
-        use_grpc (int): 
-        hst (str): 
-        svc (str): 
-        retry_interval (int): 
+        use_grpc (int):
+        hst (str):
+        svc (str):
+        retry_interval (int):
 
     Returns: N/A
-        
-    """    
+
+    """
     if use_grpc > 0:
         with grpc.insecure_channel("127.0.0.1:50001") as channel:
             stub = engine_pb2_grpc.EngineStub(channel)
@@ -1585,6 +1610,7 @@ def change_retry_svc_check_interval(use_grpc: int, hst: str, svc: str, retry_int
         f.write(cmd)
         f.close()
 
+
 def change_retry_host_check_interval(use_grpc: int, hst: str, retry_interval: int):
     """
     change_retry_host_check_interval _summary_
@@ -1592,13 +1618,13 @@ def change_retry_host_check_interval(use_grpc: int, hst: str, retry_interval: in
     Update the retry check interval for a host
 
     Args:
-        use_grpc (int):  
-        hst (str):  
-        retry_interval (int):  
+        use_grpc (int):
+        hst (str):
+        retry_interval (int):
 
     Returns: N/A
-        
-    """    
+
+    """
     if use_grpc > 0:
         with grpc.insecure_channel("127.0.0.1:50001") as channel:
             stub = engine_pb2_grpc.EngineStub(channel)
@@ -1610,21 +1636,22 @@ def change_retry_host_check_interval(use_grpc: int, hst: str, retry_interval: in
         with open(f"{VAR_ROOT}/lib/centreon-engine/config0/rw/centengine.cmd", "w") as f:
             f.write(cmd)
 
+
 def change_max_svc_check_attempts(use_grpc: int, hst: str, svc: str, max_check_attempts: int):
     """
-    change_max_svc_check_attempts 
+    change_max_svc_check_attempts
 
     Update the max check attempts for a service
 
     Args:
-        use_grpc (int): 
+        use_grpc (int):
         hst (str): host name
         svc (str): service name
         max_check_attempts (int): number of max check attempts wanted
 
     Returns: N/A
-        
-    """    
+
+    """
     if use_grpc > 0:
         with grpc.insecure_channel("127.0.0.1:50001") as channel:
             stub = engine_pb2_grpc.EngineStub(channel)
@@ -1636,20 +1663,21 @@ def change_max_svc_check_attempts(use_grpc: int, hst: str, svc: str, max_check_a
         with open(f"{VAR_ROOT}/lib/centreon-engine/config0/rw/centengine.cmd", "w") as f:
             f.write(cmd)
 
+
 def change_max_host_check_attempts(use_grpc: int, hst: str, max_check_attempts: int):
     """
-    change_max_host_check_attempts 
+    change_max_host_check_attempts
 
     Update the max check attempts for a host
 
     Args:
-        use_grpc (int): 
+        use_grpc (int):
         hst (str): service name
         max_check_attempts (int): number of max check attempts wanted
 
     Returns: N/A
 
-    """    
+    """
     if use_grpc > 0:
         with grpc.insecure_channel("127.0.0.1:50001") as channel:
             stub = engine_pb2_grpc.EngineStub(channel)
@@ -1663,20 +1691,21 @@ def change_max_host_check_attempts(use_grpc: int, hst: str, max_check_attempts:
         f.write(cmd)
         f.close()
 
+
 def change_host_check_timeperiod(use_grpc: int, hst: str, check_timeperiod: str):
     """
-    change_host_check_timeperiod 
+    change_host_check_timeperiod
 
     Update the check timeperiod for a host
 
     Args:
-        use_grpc (int):  
+        use_grpc (int):
         hst (str): host name
         check_timeperiod (str): chek period (24x7, 24x6, workhours..)
 
     Returns: N/A
-         
-    """    
+
+    """
     if use_grpc > 0:
         with grpc.insecure_channel("127.0.0.1:50001") as channel:
             stub = engine_pb2_grpc.EngineStub(channel)
@@ -1690,20 +1719,21 @@ def change_host_check_timeperiod(use_grpc: int, hst: str, check_timeperiod: str)
         f.write(cmd)
         f.close()
 
+
 def change_host_notification_timeperiod(use_grpc: int, hst: str, notification_timeperiod: str):
     """
-    change_host_notification_timeperiod 
+    change_host_notification_timeperiod
 
     Update the notification timeperiod for a host
 
     Args:
-        use_grpc (int): 
+        use_grpc (int):
         hst (str):  host nema
         notification_timeperiod (str): notification chek period (24x7, 24x6, workhours..)
 
     Returns: N/A
-        
-    """    
+
+    """
     if use_grpc > 0:
         with grpc.insecure_channel("127.0.0.1:50001") as channel:
             stub = engine_pb2_grpc.EngineStub(channel)
@@ -1717,21 +1747,22 @@ def change_host_notification_timeperiod(use_grpc: int, hst: str, notification_ti
         f.write(cmd)
         f.close()
 
+
 def change_svc_check_timeperiod(use_grpc: int, hst: str, svc: str, check_timeperiod: str):
     """
-    change_svc_check_timeperiod  
+    change_svc_check_timeperiod
 
     Update the check timeperiod for a service
 
     Args:
-        use_grpc (int):  
+        use_grpc (int):
         hst (str): host name
         svc (str): service name
         check_timeperiod (str): chek period (24x7, 24x6, workhours..)
 
     Returns: N/A
-        
-    """    
+
+    """
     if use_grpc > 0:
         with grpc.insecure_channel("127.0.0.1:50001") as channel:
             stub = engine_pb2_grpc.EngineStub(channel)
@@ -1745,9 +1776,10 @@ def change_svc_check_timeperiod(use_grpc: int, hst: str, svc: str, check_timeper
         f.write(cmd)
         f.close()
 
+
 def change_svc_notification_timeperiod(use_grpc: int, hst: str, svc: str, notification_timeperiod: str):
     """
-    change_svc_notification_timeperiod 
+    change_svc_notification_timeperiod
 
     Update the notification timeperiod for a service
 
@@ -1758,8 +1790,8 @@ def change_svc_notification_timeperiod(use_grpc: int, hst: str, svc: str, notifi
         notification_timeperiod (str): notification chek period (24x7, 24x6, workhours..)
 
     Returns: N/A
-        
-    """    
+
+    """
     if use_grpc > 0:
         with grpc.insecure_channel("127.0.0.1:50001") as channel:
             stub = engine_pb2_grpc.EngineStub(channel)
@@ -1773,19 +1805,20 @@ def change_svc_notification_timeperiod(use_grpc: int, hst: str, svc: str, notifi
         f.write(cmd)
         f.close()
 
+
 def disable_host_and_child_notifications(use_grpc: int, hst: str):
     """
-    disable_host_and_child_notifications 
+    disable_host_and_child_notifications
 
     Run the command to disable host and child notifications
 
     Args:
-        use_grpc (int): 
+        use_grpc (int):
         hst (str): host name
 
     Returns: N/A
-        
-    """    
+
+    """
     if use_grpc > 0:
         with grpc.insecure_channel("127.0.0.1:50001") as channel:
             stub = engine_pb2_grpc.EngineStub(channel)
@@ -1799,19 +1832,20 @@ def disable_host_and_child_notifications(use_grpc: int, hst: str):
         f.write(cmd)
         f.close()
 
+
 def enable_host_and_child_notifications(use_grpc: int, hst: str):
     """
-    enable_host_and_child_notifications 
+    enable_host_and_child_notifications
 
     Run the command to enable host and child notifications
 
     Args:
-        use_grpc (int): 
+        use_grpc (int):
         hst (str): host name
 
     Returns: N/A
-        
-    """    
+
+    """
     if use_grpc > 0:
         with grpc.insecure_channel("127.0.0.1:50001") as channel:
             stub = engine_pb2_grpc.EngineStub(channel)
@@ -1825,19 +1859,20 @@ def enable_host_and_child_notifications(use_grpc: int, hst: str):
         f.write(cmd)
         f.close()
 
+
 def disable_host_check(use_grpc: int, hst: str):
     """
-    disable_host_check 
+    disable_host_check
 
     Run the command to disable host check
 
     Args:
-        use_grpc (int): 
+        use_grpc (int):
         hst (str): host name
 
     Returns: N/A
-        
-    """    
+
+    """
     if use_grpc == 0:
         now = int(time.time())
         cmd = "[{}] DISABLE_HOST_CHECK;{}\n".format(
@@ -1849,17 +1884,17 @@ def disable_host_check(use_grpc: int, hst: str):
 
 def enable_host_check(use_grpc: int, hst: str):
     """
-    enable_host_check 
+    enable_host_check
 
     Run the command to enable host check
 
     Args:
-        use_grpc (int): 
+        use_grpc (int):
         hst (str): host name
 
     Returns: N/A
-        
-    """    
+
+    """
     if use_grpc == 0:
         now = int(time.time())
         cmd = "[{}] ENABLE_HOST_CHECK;{}\n".format(
@@ -1868,19 +1903,20 @@ def enable_host_check(use_grpc: int, hst: str):
         f.write(cmd)
         f.close()
 
+
 def disable_host_event_handler(use_grpc: int, hst: str):
     """
-    disable_host_event_handler 
+    disable_host_event_handler
 
     Run the command to disable host event handler
 
     Args:
-        use_grpc (int): 
+        use_grpc (int):
         hst (str): host name
 
     Returns: N/A
-        
-    """    
+
+    """
     if use_grpc == 0:
         now = int(time.time())
         cmd = "[{}] DISABLE_HOST_EVENT_HANDLER;{}\n".format(
@@ -1889,19 +1925,20 @@ def disable_host_event_handler(use_grpc: int, hst: str):
         f.write(cmd)
         f.close()
 
+
 def enable_host_event_handler(use_grpc: int, hst: str):
     """
-    enable_host_event_handler 
+    enable_host_event_handler
 
     Run the command to enable host event handler
 
     Args:
-        use_grpc (int): 
+        use_grpc (int):
         hst (str): host name
 
     Returns: N/A
-        
-    """    
+
+    """
     if use_grpc == 0:
         now = int(time.time())
         cmd = "[{}] ENABLE_HOST_EVENT_HANDLER;{}\n".format(
@@ -1910,9 +1947,10 @@ def enable_host_event_handler(use_grpc: int, hst: str):
         f.write(cmd)
         f.close()
 
+
 def disable_host_flap_detection(use_grpc: int, hst: str):
     """
-    disable_host_flap_detection 
+    disable_host_flap_detection
 
     Run the command to disable host flap detection
 
@@ -1921,8 +1959,8 @@ def disable_host_flap_detection(use_grpc: int, hst: str):
         hst (str): host name
 
     Returns: N/A
-         
-    """    
+
+    """
     if use_grpc == 0:
         now = int(time.time())
         cmd = "[{}] DISABLE_HOST_FLAP_DETECTION;{}\n".format(
@@ -1934,17 +1972,17 @@ def disable_host_flap_detection(use_grpc: int, hst: str):
 
 def enable_host_flap_detection(use_grpc: int, hst: str):
     """
-    enable_host_flap_detection  
+    enable_host_flap_detection
 
     Run the command to enable host flap detection
 
     Args:
-        use_grpc (int):  
+        use_grpc (int):
         hst (str): host name
 
     Returns: N/A
-         
-    """    
+
+    """
     if use_grpc == 0:
         now = int(time.time())
         cmd = "[{}] ENABLE_HOST_FLAP_DETECTION;{}\n".format(
@@ -1961,12 +1999,12 @@ def disable_host_notifications(use_grpc: int, hst: str):
     Run the command to disable host notifications
 
     Args:
-        use_grpc (int): 
+        use_grpc (int):
         hst (str): host name
 
     Returns: N/A
-        
-    """    
+
+    """
     if use_grpc > 0:
         with grpc.insecure_channel("127.0.0.1:50001") as channel:
             stub = engine_pb2_grpc.EngineStub(channel)
@@ -1983,17 +2021,17 @@ def disable_host_notifications(use_grpc: int, hst: str):
 
 def enable_host_notifications(use_grpc: int, hst: str):
     """
-    enable_host_notifications 
+    enable_host_notifications
 
     Run the command to enable host notifications
 
     Args:
-        use_grpc (int):  
+        use_grpc (int):
         hst (str): host name
 
     Returns: N/A
-        
-    """    
+
+    """
     if use_grpc > 0:
         with grpc.insecure_channel("127.0.0.1:50001") as channel:
             stub = engine_pb2_grpc.EngineStub(channel)
@@ -2010,19 +2048,19 @@ def enable_host_notifications(use_grpc: int, hst: str):
 
 def update_ano_sensitivity(use_grpc: int, hst: str, serv: str, sensitivity: float):
     """
-    update_ano_sensitivity 
+    update_ano_sensitivity
 
-    Update the anomaly detection sensitivity 
+    Update the anomaly detection sensitivity
 
     Args:
-        use_grpc (int): 
+        use_grpc (int):
         hst (str):  host name
         serv (str): service name
-        sensitivity (float): 
+        sensitivity (float):
 
     Returns: N/A
-        
-    """    
+
+    """
     if use_grpc > 0:
         with grpc.insecure_channel("127.0.0.1:50001") as channel:
             stub = engine_pb2_grpc.EngineStub(channel)
@@ -2039,17 +2077,17 @@ def update_ano_sensitivity(use_grpc: int, hst: str, serv: str, sensitivity: floa
 
 def disable_host_svc_checks(use_grpc: int, hst: str):
     """
-    disable_host_svc_checks 
+    disable_host_svc_checks
 
     Run the command to disable host service checks
 
     Args:
-        use_grpc (int): 
+        use_grpc (int):
         hst (str): host name
 
     Returns: N/A
-        
-    """    
+
+    """
     if use_grpc == 0:
         now = int(time.time())
         cmd = "[{}] DISABLE_HOST_SVC_CHECKS;{}\n".format(
@@ -2066,12 +2104,12 @@ def enable_host_svc_checks(use_grpc: int, hst: str):
     Run the command to enable host service checks
 
     Args:
-        use_grpc (int): 
+        use_grpc (int):
         hst (str): host name
 
     Returns: N/A
-        
-    """    
+
+    """
     if use_grpc == 0:
         now = int(time.time())
         cmd = "[{}] ENABLE_HOST_SVC_CHECKS;{}\n".format(
@@ -2083,17 +2121,17 @@ def enable_host_svc_checks(use_grpc: int, hst: str):
 
 def disable_host_svc_notifications(use_grpc: int, hst: str):
     """
-    disable_host_svc_notifications 
+    disable_host_svc_notifications
 
     Run the command to disable host service notifications
 
     Args:
-        use_grpc (int): 
+        use_grpc (int):
         hst (str): host name
 
     Returns: N/A
-        
-    """    
+
+    """
     if use_grpc == 0:
         now = int(time.time())
         cmd = "[{}] DISABLE_HOST_SVC_NOTIFICATIONS;{}\n".format(
@@ -2105,17 +2143,17 @@ def disable_host_svc_notifications(use_grpc: int, hst: str):
 
 def enable_host_svc_notifications(use_grpc: int, hst: str):
     """
-    enable_host_svc_notifications 
+    enable_host_svc_notifications
 
     Run the command to enable host service notifications
 
     Args:
-        use_grpc (int): 
+        use_grpc (int):
         hst (str): host name
 
     Returns: N/A
-        
-    """    
+
+    """
     if use_grpc == 0:
         now = int(time.time())
         cmd = "[{}] ENABLE_HOST_SVC_NOTIFICATIONS;{}\n".format(
@@ -2127,17 +2165,17 @@ def enable_host_svc_notifications(use_grpc: int, hst: str):
 
 def disable_passive_host_checks(use_grpc: int, hst: str):
     """
-    disable_passive_host_checks 
+    disable_passive_host_checks
 
     Run the command to disable passive host checks
 
     Args:
-        use_grpc (int): 
+        use_grpc (int):
         hst (str): host name
 
     Returns: N/A
-        
-    """    
+
+    """
     if use_grpc == 0:
         now = int(time.time())
         cmd = "[{}] DISABLE_PASSIVE_HOST_CHECKS;{}\n".format(
@@ -2149,17 +2187,17 @@ def disable_passive_host_checks(use_grpc: int, hst: str):
 
 def enable_passive_host_checks(use_grpc: int, hst: str):
     """
-    enable_passive_host_checks 
+    enable_passive_host_checks
 
     Run the command to enable passive host checks
 
     Args:
-        use_grpc (int): 
+        use_grpc (int):
         hst (str): host name
 
     Returns: N/A
-        
-    """    
+
+    """
     if use_grpc == 0:
         now = int(time.time())
         cmd = "[{}] ENABLE_PASSIVE_HOST_CHECKS;{}\n".format(
@@ -2171,18 +2209,18 @@ def enable_passive_host_checks(use_grpc: int, hst: str):
 
 def disable_passive_svc_checks(use_grpc: int, hst: str, svc: str):
     """
-    disable_passive_svc_checks 
+    disable_passive_svc_checks
 
     Run the command to disable passive service checks
 
     Args:
-        use_grpc (int): 
+        use_grpc (int):
         hst (str): host name
         svc (str): service name
 
     Returns: N/A
-        
-    """    
+
+    """
     if use_grpc == 0:
         now = int(time.time())
         cmd = "[{}] DISABLE_PASSIVE_SVC_CHECKS;{};{}\n".format(
@@ -2194,18 +2232,18 @@ def disable_passive_svc_checks(use_grpc: int, hst: str, svc: str):
 
 def enable_passive_svc_checks(use_grpc: int, hst: str, svc: str):
     """
-    enable_passive_svc_checks 
+    enable_passive_svc_checks
 
     Run the command to enable passive service checks
 
     Args:
-        use_grpc (int): 
+        use_grpc (int):
         hst (str): host name
         svc (str): service name
 
     Returns: N/A
-        
-    """    
+
+    """
     if use_grpc == 0:
         now = int(time.time())
         cmd = "[{}] ENABLE_PASSIVE_SVC_CHECKS;{};{}\n".format(
@@ -2214,6 +2252,7 @@ def enable_passive_svc_checks(use_grpc: int, hst: str, svc: str):
         f.write(cmd)
         f.close()
 
+
 def start_obsessing_over_host(use_grpc: int, hst: str):
     """
     start_obsessing_over_host _summary_
@@ -2221,12 +2260,12 @@ def start_obsessing_over_host(use_grpc: int, hst: str):
     Run the command to start obsessing over a host
 
     Args:
-        use_grpc (int): 
+        use_grpc (int):
         hst (str): host name
 
     Returns: N/A
-        
-    """    
+
+    """
     if use_grpc == 0:
         now = int(time.time())
         cmd = "[{}] START_OBSESSING_OVER_HOST;{}\n".format(
@@ -2235,19 +2274,20 @@ def start_obsessing_over_host(use_grpc: int, hst: str):
         f.write(cmd)
         f.close()
 
+
 def stop_obsessing_over_host(use_grpc: int, hst: str):
     """
-    stop_obsessing_over_host 
+    stop_obsessing_over_host
 
     Run the command to stop obsessing over a host
 
     Args:
-        use_grpc (int): 
+        use_grpc (int):
         hst (str): host name
 
     Returns: N/A
-        
-    """ 
+
+    """
     if use_grpc == 0:
         now = int(time.time())
         cmd = "[{}] STOP_OBSESSING_OVER_HOST;{}\n".format(
@@ -2256,20 +2296,21 @@ def stop_obsessing_over_host(use_grpc: int, hst: str):
         f.write(cmd)
         f.close()
 
+
 def start_obsessing_over_svc(use_grpc: int, hst: str, svc: str):
     """
-    start_obsessing_over_svc 
+    start_obsessing_over_svc
 
     Run the command to start obsessing over a service
 
     Args:
-        use_grpc (int): 
+        use_grpc (int):
         hst (str): host name
         svc (str): service name
 
     Returns: N/A
-        
-    """    
+
+    """
     if use_grpc == 0:
         now = int(time.time())
         cmd = "[{}] START_OBSESSING_OVER_SVC;{};{}\n".format(
@@ -2278,20 +2319,21 @@ def start_obsessing_over_svc(use_grpc: int, hst: str, svc: str):
         f.write(cmd)
         f.close()
 
+
 def stop_obsessing_over_svc(use_grpc: int, hst: str, svc: str):
     """
-    stop_obsessing_over_svc 
+    stop_obsessing_over_svc
 
     Run the command to stop obsessing over a service
 
     Args:
-        use_grpc (int): 
+        use_grpc (int):
         hst (str): host name
         svc (str): service name
 
     Returns: N/A
-       
-    """    
+
+    """
     if use_grpc == 0:
         now = int(time.time())
         cmd = "[{}] STOP_OBSESSING_OVER_SVC;{};{}\n".format(
@@ -2314,7 +2356,7 @@ def wrapper(*args):
 @external_command
 def service_ext_commands(hst: str, svc: str, state: int, output: str):
     """
-    service_ext_commands 
+    service_ext_commands
 
     Run the command to process a service check result
 
@@ -2329,6 +2371,7 @@ def service_ext_commands(hst: str, svc: str, state: int, output: str):
     """
     return f"PROCESS_SERVICE_CHECK_RESULT;{hst};{svc};{state};{output}\n"
 
+
 @external_command
 def process_host_check_result(hst: str, state: int, output: str):
     return f"PROCESS_HOST_CHECK_RESULT;{hst};{state};{output}\n"
@@ -2337,7 +2380,7 @@ def process_host_check_result(hst: str, state: int, output: str):
 @external_command
 def schedule_service_downtime(hst: str, svc: str, duration: int):
     """
-    schedule_service_downtime 
+    schedule_service_downtime
 
     Run the command to schedule a service downtime
 
@@ -2347,8 +2390,8 @@ def schedule_service_downtime(hst: str, svc: str, duration: int):
         duration (int): duration of the downtime in seconds
 
     Returns: N/A
-        
-    """    
+
+    """
     now = int(time.time())
     return f"SCHEDULE_SVC_DOWNTIME;{hst};{svc};{now};{now+int(duration)};0;0;{duration};admin;Downtime set by admin\n"
 
@@ -2361,16 +2404,16 @@ def schedule_service_fixed_downtime(hst: str, svc: str, duration: int):
 
 def schedule_host_fixed_downtime(poller: int, hst: str, duration: int):
     """
-    schedule_host_fixed_downtime  
+    schedule_host_fixed_downtime
 
     Run the command to schedule a host downtime
 
     Args:
-        poller (int): 
+        poller (int):
         hst (str): host name
         duration (int): duration of the downtime
 
-    """    
+    """
     now = int(time.time())
     cmd1 = "[{1}] SCHEDULE_HOST_DOWNTIME;{0};{1};{2};1;0;;admin;Downtime set by admin\n".format(
         hst, now, now + duration)
@@ -2382,9 +2425,10 @@ def schedule_host_fixed_downtime(poller: int, hst: str, duration: int):
     f.write(cmd2)
     f.close()
 
+
 def schedule_host_downtime(poller: int, hst: str, duration: int):
     """
-    schedule_host_downtime 
+    schedule_host_downtime
 
     Run the command to schedule a host downtime
 
@@ -2394,8 +2438,8 @@ def schedule_host_downtime(poller: int, hst: str, duration: int):
         duration (int): period of the downtime wanted in second
 
     Returns: N/A
-        
-    """    
+
+    """
     now = int(time.time())
     cmd1 = "[{1}] SCHEDULE_HOST_DOWNTIME;{0};{1};{2};1;0;{3};admin;Downtime set by admin\n".format(
         hst, now, now + duration, duration)
@@ -2407,10 +2451,11 @@ def schedule_host_downtime(poller: int, hst: str, duration: int):
     f.write(cmd2)
     f.close()
 
+
 def delete_host_downtimes(poller: int, hst: str):
     """
-    
-    delete_host_downtimes 
+
+    delete_host_downtimes
 
     Run the command to delete a host downtime
 
@@ -2419,8 +2464,8 @@ def delete_host_downtimes(poller: int, hst: str):
         hst (str): host name
 
     Returns: N/A
-        
-    """    
+
+    """
     now = int(time.time())
     cmd = "[{}] DEL_HOST_DOWNTIME_FULL;{};;;;;;;;\n".format(now, hst)
     f = open(
@@ -2428,21 +2473,22 @@ def delete_host_downtimes(poller: int, hst: str):
     f.write(cmd)
     f.close()
 
+
 def delete_service_downtime_full(poller: int, hst: str, svc: str):
     """
-    
-    delete_service_downtime_full 
+
+    delete_service_downtime_full
 
     Run the command to delete a service downtime
 
     Args:
-        poller (int):  poller id 
+        poller (int):  poller id
         hst (str): host name
         svc (str):  service name
 
     Returns: N/A
-        
-    """    
+
+    """
     now = int(time.time())
     cmd = f"[{now}] DEL_SVC_DOWNTIME_FULL;{hst};{svc};;;;;;;\n"
     f = open(
@@ -2453,7 +2499,7 @@ def delete_service_downtime_full(poller: int, hst: str, svc: str):
 
 def schedule_forced_svc_check(host: str, svc: str, pipe: str = f"{VAR_ROOT}/lib/centreon-engine/config0/rw/centengine.cmd"):
     """
-    schedule_forced_svc_check 
+    schedule_forced_svc_check
 
     Run the command to schedule a forced service check
 
@@ -2463,8 +2509,8 @@ def schedule_forced_svc_check(host: str, svc: str, pipe: str = f"{VAR_ROOT}/lib/
         pipe (str, optional): Defaults to VAR_ROOT+"/lib/centreon-engine/config0/rw/centengine.cmd".
 
     Returns: N/A
-    
-    """    
+
+    """
     now = int(time.time())
     f = open(pipe, "w")
     cmd = "[{2}] SCHEDULE_FORCED_SVC_CHECK;{0};{1};{2}\n".format(
@@ -2476,8 +2522,8 @@ def schedule_forced_svc_check(host: str, svc: str, pipe: str = f"{VAR_ROOT}/lib/
 
 def schedule_forced_host_check(host: str, pipe: str = f"{VAR_ROOT}/lib/centreon-engine/config0/rw/centengine.cmd"):
     """
-    
-    schedule_forced_host_check 
+
+    schedule_forced_host_check
 
     Run the command to schedule a forced host check
 
@@ -2486,8 +2532,8 @@ def schedule_forced_host_check(host: str, pipe: str = f"{VAR_ROOT}/lib/centreon-
         pipe (str, optional): Defaults to VAR_ROOT+"/lib/centreon-engine/config0/rw/centengine.cmd".
 
     Returns: N/A
-       
-    """ 
+
+    """
     now = int(time.time())
     cmd = f"[{now}] SCHEDULE_FORCED_HOST_CHECK;{host};{now}\n"
     with open(pipe, "w") as f:
@@ -2496,7 +2542,7 @@ def schedule_forced_host_check(host: str, pipe: str = f"{VAR_ROOT}/lib/centreon-
 
 def create_severities_file(poller: int, nb: int, offset: int = 1):
     """
-    create_severities_file 
+    create_severities_file
 
     Run the command to create severities file
 
@@ -2506,14 +2552,15 @@ def create_severities_file(poller: int, nb: int, offset: int = 1):
         offset (int, optional): Defaults to 1.
 
     Returns: N/A
-        
-    """    
+
+    """
     engine.create_severities(poller, nb, offset)
 
+
 def create_escalations_file(poller: int, name: int, SG: str, contactgroup: str):
     """
-    
-    create_escalations_file 
+
+    create_escalations_file
 
     Create escalations file
 
@@ -2524,33 +2571,34 @@ def create_escalations_file(poller: int, name: int, SG: str, contactgroup: str):
         contactgroup (str): name of contact group
 
     Returns: N/A
-        
-    """    
+
+    """
     engine.create_escalations_file(poller, name, SG, contactgroup)
 
+
 def create_template_file(poller: int, typ: str, what: str, ids: list):
     """
-    
-    create_template_file 
+
+    create_template_file
 
     Run the command to create template file
 
     Args:
         poller (int): poller id
-        typ (str): 
-        what (str): 
-        ids (list): 
+        typ (str):
+        what (str):
+        ids (list):
 
     Returns: N/A
-        
-    """    
+
+    """
     engine.create_template_file(poller, typ, what, ids)
 
 
 def create_tags_file(poller: int, nb: int, offset: int = 1, tag_type: str = ""):
     """
-    
-    create_tags_file 
+
+    create_tags_file
 
     Run the command to create tags file
 
@@ -2560,8 +2608,8 @@ def create_tags_file(poller: int, nb: int, offset: int = 1, tag_type: str = ""):
         offset (int, optional): Defaults to 1.
 
     Returns: N/A
-        
-    """    
+
+    """
     engine.create_tags(poller, nb, offset, tag_type)
 
 
@@ -2600,8 +2648,8 @@ def engine_config_remove_tag(poller: int, tag_id: int):
 
 def config_engine_add_cfg_file(poller: int, cfg: str):
     """
-    
-    config_engine_add_cfg_file 
+
+    config_engine_add_cfg_file
 
     Run the command to add a cfg file to the engine
 
@@ -2610,8 +2658,8 @@ def config_engine_add_cfg_file(poller: int, cfg: str):
         cfg (str): configuration file name
 
     Returns: N/A
-        
-    """    
+
+    """
     ff = open("{}/config{}/centengine.cfg".format(CONF_DIR, poller), "r")
     lines = ff.readlines()
     ff.close()
@@ -2625,21 +2673,22 @@ def config_engine_add_cfg_file(poller: int, cfg: str):
     ff.writelines(lines)
     ff.close()
 
+
 def add_severity_to_services(poller: int, severity_id: int, svc_lst):
     """
-    
-    add_severity_to_services 
+
+    add_severity_to_services
 
     Add severity to services
 
     Args:
-        poller (int): 
-        severity_id (int): 
-        svc_lst (list): 
+        poller (int):
+        severity_id (int):
+        svc_lst (list):
 
     Returns: N/A
-        
-    """    
+
+    """
 
     ff = open("{}/config{}/services.cfg".format(CONF_DIR, poller), "r")
     lines = ff.readlines()
@@ -2655,20 +2704,21 @@ def add_severity_to_services(poller: int, severity_id: int, svc_lst):
     ff.writelines(lines)
     ff.close()
 
+
 def set_services_passive(poller: int, srv_regex):
     """
-    
-    set_services_passive 
+
+    set_services_passive
 
     "Run the command to set services passive
 
     Args:
-        poller (int): 
+        poller (int):
         srv_regex (str): service name
 
     Returns: N/A
-        
-    """    
+
+    """
 
     ff = open("{}/config{}/services.cfg".format(CONF_DIR, poller), "r")
     lines = ff.readlines()
@@ -2697,21 +2747,22 @@ def set_services_passive(poller: int, srv_regex):
     ff.writelines(lines)
     ff.close()
 
+
 def add_severity_to_hosts(poller: int, severity_id: int, svc_lst):
     """
-    
+
     add_severity_to_hosts _summary_
 
     Run the command to add severity to hosts
 
     Args:
-        poller (int): 
-        severity_id (int): 
-        svc_lst (_type_): 
+        poller (int):
+        severity_id (int):
+        svc_lst (_type_):
 
     Returns: n:a
-        
-    """    
+
+    """
     ff = open("{}/config{}/hosts.cfg".format(CONF_DIR, poller), "r")
     lines = ff.readlines()
     ff.close()
@@ -2726,52 +2777,23 @@ def add_severity_to_hosts(poller: int, severity_id: int, svc_lst):
     ff.writelines(lines)
     ff.close()
 
-def add_template_to_services(poller: int, tmpl: str, svc_lst):
-    """
-    
-    add_template_to_services 
-
-    Run the command to add template to services
-
-    Args:
-        poller (int): 
-        tmpl (str): 
-        svc_lst (_type_): 
-
-    Returns: N/A
-   
-    """    
-
-    ff = open("{}/config{}/services.cfg".format(CONF_DIR, poller), "r")
-    lines = ff.readlines()
-    ff.close()
-    r = re.compile(r"^\s*_SERVICE_ID\s*(\d+)$")
-    for i in range(len(lines)):
-        m = r.match(lines[i])
-        if m is not None and m.group(1) in svc_lst:
-            lines.insert(
-                i + 1, "    use                     {}\n".format(tmpl))
-
-    ff = open("{}/config{}/services.cfg".format(CONF_DIR, poller), "w")
-    ff.writelines(lines)
-    ff.close()
 
 def add_tags_to_services(poller: int, type: str, tag_id: str, svc_lst):
     """
-    
-    add_tags_to_services 
+
+    add_tags_to_services
 
     Run the command to add tags to services
 
     Args:
-        poller (int): 
-        type (str): 
-        tag_id (str): 
-        svc_lst (_type_): 
+        poller (int):
+        type (str):
+        tag_id (str):
+        svc_lst (_type_):
 
     Returns: N/A
-        
-    """    
+
+    """
 
     ff = open("{}/config{}/services.cfg".format(CONF_DIR, poller), "r")
     lines = ff.readlines()
@@ -2786,33 +2808,30 @@ def add_tags_to_services(poller: int, type: str, tag_id: str, svc_lst):
     ff.writelines(lines)
     ff.close()
 
+
 def remove_severities_from_services(poller: int):
     """
-    
-    remove_severities_from_services 
+
+    remove_severities_from_services
 
     Remove severities from services
 
     Args:
-        poller (int): 
+        poller (int):
 
     Returns: N/A
-        
-    """    
-
-    ff = open("{}/config{}/services.cfg".format(CONF_DIR, poller), "r")
-    lines = ff.readlines()
-    ff.close()
+    """
+    with open("{}/config{}/services.cfg".format(CONF_DIR, poller), "r") as ff:
+        lines = ff.readlines()
     r = re.compile(r"^\s*severity_id\s*\d+$")
-    out = [l for l in lines if not r.match(l)]
-    ff = open("{}/config{}/services.cfg".format(CONF_DIR, poller), "w")
-    ff.writelines(out)
-    ff.close()
+    out = [line for line in lines if not r.match(line)]
+    with open("{}/config{}/services.cfg".format(CONF_DIR, poller), "w") as ff:
+        ff.writelines(out)
+
 
 def remove_severities_from_hosts(poller: int):
     """
-    
-    remove_severities_from_hosts 
+    remove_severities_from_hosts
 
     Remove severities from hosts
 
@@ -2820,21 +2839,19 @@ def remove_severities_from_hosts(poller: int):
         poller (int):
 
     Returns:
-        
-    """    
-    ff = open("{}/config{}/hosts.cfg".format(CONF_DIR, poller), "r")
-    lines = ff.readlines()
-    ff.close()
+
+    """
+    with open("{}/config{}/hosts.cfg".format(CONF_DIR, poller), "r") as ff:
+        lines = ff.readlines()
     r = re.compile(r"^\s*severity_id\s*\d+$")
-    out = [l for l in lines if not r.match(l)]
-    ff = open("{}/config{}/hosts.cfg".format(CONF_DIR, poller), "w")
-    ff.writelines(out)
-    ff.close()
+    out = [line for line in lines if not r.match(line)]
+    with open(f"{CONF_DIR}/config{poller}/hosts.cfg", "w") as ff:
+        ff.writelines(out)
+
 
 def check_search(debug_file_path: str, str_to_search, timeout=TIMEOUT):
     """
-    
-    check_search 
+    check_search
 
     Function that search a check, retrieve command index and return check resultBthen it searchs the string "connector::run: id=1090", and then search "connector::_recv_query_execute: id=1090," and return this line
 
@@ -2842,14 +2859,13 @@ def check_search(debug_file_path: str, str_to_search, timeout=TIMEOUT):
         debug_file_path (str): path of the debug log file
         str_to_search (_type_): string after which we will start connector::run search
         timeout (_type_, optional): Defaults to TIMEOUT.
-        
+
     Example:
     | ${search_result} | `Check Search` | /var/log/centreon-engine/centengine.debug | "connector::run: id=1090" |
     | Should Contain | ${search_result} | "connector::_recv_query_execute: id=1090," |
 
     Returns: N/A
-        
-    """    
+    """
     limit = time.time() + timeout
     r_query_execute = "none"
     while time.time() < limit:
@@ -2879,20 +2895,21 @@ def check_search(debug_file_path: str, str_to_search, timeout=TIMEOUT):
     else:
         return f"check_search doesn't find <<{str_to_search}>>"
 
+
 def add_tags_to_hosts(poller: int, type: str, tag_id: str, hst_lst):
     """
-    
-    add_tags_to_hosts 
+
+    add_tags_to_hosts
 
     Args:
-        poller (int): 
-        type (str): 
-        tag_id (str): 
-        hst_lst (_type_): 
+        poller (int):
+        type (str):
+        tag_id (str):
+        hst_lst (_type_):
 
     Returns: N/A
-        
-    """    
+
+    """
     ff = open("{}/config{}/hosts.cfg".format(CONF_DIR, poller), "r")
     lines = ff.readlines()
     ff.close()
@@ -2907,49 +2924,44 @@ def add_tags_to_hosts(poller: int, type: str, tag_id: str, hst_lst):
     ff.writelines(lines)
     ff.close()
 
+
 def remove_tags_from_services(poller: int, type: str):
     """
-    
-    remove_tags_from_services  
+
+    remove_tags_from_services
 
     Remove tags from services
 
     Args:
-        poller (int):  
-        type (str):  
-     
-    """    
+        poller (int):
+        type (str):
 
-    ff = open("{}/config{}/services.cfg".format(CONF_DIR, poller), "r")
-    lines = ff.readlines()
-    ff.close()
+    """
+
+    with open("{}/config{}/services.cfg".format(CONF_DIR, poller), "r") as ff:
+        lines = ff.readlines()
     r = re.compile(r"^\s*" + type + r"\s*[0-9,]+$")
-    lines = [l for l in lines if not r.match(l)]
-    ff = open("{}/config{}/services.cfg".format(CONF_DIR, poller), "w")
-    ff.writelines(lines)
-    ff.close()
+    lines = [line for line in lines if not r.match(line)]
+    with open("{}/config{}/services.cfg".format(CONF_DIR, poller), "w") as ff:
+        ff.writelines(lines)
+
 
 def remove_tags_from_hosts(poller: int, type: str):
     """
-    
-    remove_tags_from_hosts 
+    remove_tags_from_hosts
 
     Remove tags from hosts
 
     Args:
-        poller (int): 
-        type (str):  
-
-    """    
-
-    ff = open("{}/config{}/hosts.cfg".format(CONF_DIR, poller), "r")
-    lines = ff.readlines()
-    ff.close()
+        poller (int):
+        type (str):
+    """
+    with open(f"{CONF_DIR}/config{poller}/hosts.cfg", "r") as ff:
+        lines = ff.readlines()
     r = re.compile(r"^\s*" + type + r"\s*[0-9,]+$")
-    lines = [l for l in lines if not r.match(l)]
-    ff = open("{}/config{}/hosts.cfg".format(CONF_DIR, poller), "w")
-    ff.writelines(lines)
-    ff.close()
+    lines = [line for line in lines if not r.match(line)]
+    with open(f"{CONF_DIR}/config{poller}/hosts.cfg", "w") as ff:
+        ff.writelines(lines)
 
 
 def add_template_to_services(poller: int, tmpl: str, svc_lst):
@@ -2959,23 +2971,21 @@ def add_template_to_services(poller: int, tmpl: str, svc_lst):
     Run the command to add template to services
 
     Args:
-        poller (int): 
+        poller (int):
         tmpl (str): template used by the service
         svc_lst (list): list of services wanted
-    """    
-    ff = open("{}/config{}/services.cfg".format(CONF_DIR, poller), "r")
-    lines = ff.readlines()
-    ff.close()
+    """
+    with open("{}/config{}/services.cfg".format(CONF_DIR, poller), "r") as ff:
+        lines = ff.readlines()
     r = re.compile(r"^\s*_SERVICE_ID\s*(\d+)$")
     for i in range(len(lines)):
         m = r.match(lines[i])
         if m is not None and m.group(1) in svc_lst:
             lines.insert(
-                i + 1, "    use                     {}\n".format(tmpl))
+                i + 1, f"    use                     {tmpl}\n")
 
-    ff = open("{}/config{}/services.cfg".format(CONF_DIR, poller), "w")
-    ff.writelines(lines)
-    ff.close()
+    with open("{}/config{}/services.cfg".format(CONF_DIR, poller), "w") as ff:
+        ff.writelines(lines)
 
 
 def add_template_to_hosts(poller: int, tmpl: str, hst_lst):
@@ -3004,32 +3014,32 @@ def add_template_to_hosts(poller: int, tmpl: str, hst_lst):
     ff.writelines(lines)
     ff.close()
 
+
 def config_engine_remove_cfg_file(poller: int, fic: str):
     """
-    
-    config_engine_remove_cfg_file  
+
+    config_engine_remove_cfg_file
 
     Run the command to remove cfg file
 
     Args:
-        poller (int):  
-        fic (str): 
+        poller (int):
+        fic (str):
 
-    """    
-    ff = open("{}/config{}/centengine.cfg".format(CONF_DIR, poller), "r")
-    lines = ff.readlines()
-    ff.close()
+    """
+    with open("{}/config{}/centengine.cfg".format(CONF_DIR, poller), "r") as ff:
+        lines = ff.readlines()
     r = re.compile(
         r"^\s*cfg_file=" + ETC_ROOT + "/centreon-engine/config{}/{}".format(poller, fic))
-    linesearch = [l for l in lines if not r.match(l)]
-    ff = open("{}/config{}/centengine.cfg".format(CONF_DIR, poller), "w")
-    ff.writelines(linesearch)
-    ff.close()
+    linesearch = [line for line in lines if not r.match(line)]
+    with open("{}/config{}/centengine.cfg".format(CONF_DIR, poller), "w") as ff:
+        ff.writelines(linesearch)
+
 
 def process_service_check_result_with_metrics(hst: str, svc: str, state: int, output: str, metrics: int, config='config0', metric_name='metric'):
     """
-    
-    process_service_check_result_with_metrics  
+
+    process_service_check_result_with_metrics
 
     Run the command to process service check result with metrics
 
@@ -3053,10 +3063,11 @@ def process_service_check_result_with_metrics(hst: str, svc: str, state: int, ou
     full_output = " ".join(pd)
     process_service_check_result(hst, svc, state, full_output, config)
 
+
 def process_service_check_result(hst: str, svc: str, state: int, output: str, config='config0', use_grpc=0, nb_check=1):
     """
-    
-    process_service_check_result  
+
+    process_service_check_result
 
     Run the command to process service check result
 
@@ -3071,7 +3082,7 @@ def process_service_check_result(hst: str, svc: str, state: int, output: str, co
 
     Returns:
         str: output
-    """    
+    """
     if use_grpc > 0:
         port = 50001 + int(config[6:])
         with grpc.insecure_channel(f"127.0.0.1:{port}") as channel:
@@ -3096,10 +3107,11 @@ def process_service_check_result(hst: str, svc: str, state: int, output: str, co
                     cmd = f"[{now}] PROCESS_SERVICE_CHECK_RESULT;{hst};{svc};{state};{output}_{i}\n"
                     f.write(cmd)
 
+
 @external_command
 def acknowledge_service_problem(hst, service, typ='NORMAL'):
     """
-    
+
     acknowledge_service_problem _summary_
 
     Run the command to acknowledge service problem
@@ -3111,7 +3123,7 @@ def acknowledge_service_problem(hst, service, typ='NORMAL'):
 
     Returns: N/A
 
-    """    
+    """
     if typ == 'NORMAL':
         logger.console('acknowledgement is normal')
         sticky = 1
@@ -3128,8 +3140,8 @@ def acknowledge_service_problem(hst, service, typ='NORMAL'):
 @external_command
 def remove_service_acknowledgement(hst, service):
     """
-    
-    remove_service_acknowledgement  
+
+    remove_service_acknowledgement
 
    Remove service acknowledgement
 
@@ -3138,75 +3150,75 @@ def remove_service_acknowledgement(hst, service):
         service (str): service name
 
     Returns: N/A
-        
-    """    
+
+    """
     return f"REMOVE_SVC_ACKNOWLEDGEMENT;{hst};{service}\n"
 
 
 @external_command
 def send_custom_host_notification(hst, notification_option, author, comment):
     """
-    
-    send_custom_host_notification 
+
+    send_custom_host_notification
 
     Run the command to send custom host notification
 
     Args:
-        hst (str): 
-        notification_option (int): 
-        author (str): 
-        comment (str): 
+        hst (str):
+        notification_option (int):
+        author (str):
+        comment (str):
 
     Returns: N/A
-        
-    """    
+
+    """
     return f"SEND_CUSTOM_HOST_NOTIFICATION;{hst};{notification_option};{author};{comment}\n"
 
 
 @external_command
 def add_svc_comment(host_name, svc_description, persistent, user_name, comment):
     """
-    
-    add_svc_comment 
+
+    add_svc_comment
 
     Run the command to add a service comment
 
     Args:
-        host_name (str): 
-        svc_description (str): 
-        persistent (int): 
-        user_name (str): 
-        comment (str): 
+        host_name (str):
+        svc_description (str):
+        persistent (int):
+        user_name (str):
+        comment (str):
 
     Returns: N/A
-        
-    """    
+
+    """
     return f"ADD_SVC_COMMENT;{host_name};{svc_description};{persistent};{user_name};{comment}\n"
 
 
 @external_command
 def add_host_comment(host_name, persistent, user_name, comment):
     """
-    
-    add_host_comment 
+
+    add_host_comment
 
     Args:
-        host_name (str:  
-        persistent (int): 
-        user_name (str): 
-        comment (str): 
+        host_name (str:
+        persistent (int):
+        user_name (str):
+        comment (str):
 
     Returns: N/A
-        
-    """    
+
+    """
     return f"ADD_HOST_COMMENT;{host_name};{persistent};{user_name};{comment}\n"
 
 
 @external_command
 def del_host_comment(comment_id):
     """
-    
-    del_host_comment  
+
+    del_host_comment
 
     Delete a host comment
 
@@ -3214,8 +3226,8 @@ def del_host_comment(comment_id):
         comment_id (int):
 
     Returns:
-        
-    """    
+
+    """
 
     return f"DEL_HOST_COMMENT;{comment_id}\n"
 
@@ -3223,8 +3235,8 @@ def del_host_comment(comment_id):
 @external_command
 def change_host_check_command(hst: str, Check_Command: str):
     """
-    
-    change_host_check_command 
+
+    change_host_check_command
 
     Update the check command of a host
 
@@ -3233,88 +3245,88 @@ def change_host_check_command(hst: str, Check_Command: str):
         Check_Command (str): check command name
 
     Returns: N/A
-         
-    """    
+
+    """
     return f"CHANGE_HOST_CHECK_COMMAND;{hst};{Check_Command}\n"
 
 
 @external_command
 def change_custom_host_var_command(hst: str, var_name: str, var_value):
     """
-    
-    change_custom_host_var_command  
+
+    change_custom_host_var_command
 
     Run the command to change a custom host variable
 
     Args:
-        hst (str):  
-        var_name (str):  
-        var_value (_type_):  
+        hst (str):
+        var_name (str):
+        var_value (_type_):
 
     Returns: N/A
-     
-    """    
+
+    """
     return "CHANGE_CUSTOM_HOST_VAR;{};{};{}\n".format(hst, var_name, var_value)
 
 
 @external_command
 def change_custom_svc_var_command(hst: str, svc: str, var_name: str, var_value):
     """
-    
-    change_custom_svc_var_command 
+
+    change_custom_svc_var_command
 
     Run the command to change a custom service variable
 
     Args:
         hst (str): host name
         svc (str): service name
-        var_name (str): 
-        var_value (_type_): 
+        var_name (str):
+        var_value (_type_):
 
     Returns: N/A
-        
-    """    
+
+    """
     return "CHANGE_CUSTOM_SVC_VAR;{};{};{};{}\n".format(hst, svc, var_name, var_value)
 
 
 @external_command
 def change_global_host_event_handler(var_value: str):
     """
-    
+
     change_global_host_event_handler _summary_
 
     Run the command to change the global host event handler
 
     Args:
-        var_value (str): 
+        var_value (str):
 
     Returns: N/A
-        
-    """    
+
+    """
     return "CHANGE_GLOBAL_HOST_EVENT_HANDLER;{}\n".format(var_value)
 
 
 @external_command
 def change_global_svc_event_handler(var_value: str):
     """
-    
+
     change_global_svc_event_handler _Change Global Svc Event Handler_
 
     Run the command to change the global service event handler
 
     Args:
-        var_value (str): 
+        var_value (str):
 
     Returns: N/A
 
-    """    
+    """
     return "CHANGE_GLOBAL_SVC_EVENT_HANDLER;{}\n".format(var_value)
 
 
 @external_command
 def set_svc_notification_number(host_name: string, svc_description: string, value):
     """
-    
+
     set_svc_notification_number _Set Svc Notification Number_
 
     Run the command to set the number of notifications for a service
@@ -3325,30 +3337,31 @@ def set_svc_notification_number(host_name: string, svc_description: string, valu
         value (int): notification number wanted
 
     Returns: N/A
-        
-    """    
+
+    """
     return "SET_SVC_NOTIFICATION_NUMBER;{};{};{}\n".format(host_name, svc_description, value)
 
+
 def create_anomaly_threshold_file(path: string, host_id: int, service_id: int, metric_name: string, values: array):
     """
-    
+
     create_anomaly_threshold_file _Create Anomaly Threshold File_
 
     Run the command to create an anomaly threshold file
 
     Args:
-        path (string): 
-        host_id (int): 
-        service_id (int): 
-        metric_name (string): 
-        values (array): 
+        path (string):
+        host_id (int):
+        service_id (int):
+        metric_name (string):
+        values (array):
 
     Example:
     | `Create Anomaly Threshold File` | /tmp/anomaly_threshold.json | 1 | 1 | metric_1 | ${values} |
 
     Returns: N/A
-     
-    """    
+
+    """
     f = open(path, "w")
     f.write("""[
     {{
@@ -3374,27 +3387,28 @@ def create_anomaly_threshold_file(path: string, host_id: int, service_id: int, m
 """)
     f.close()
 
+
 def create_anomaly_threshold_file_V2(path: string, host_id: int, service_id: int, metric_name: string, sensitivity: float, values: array):
     """
-    
+
     create_anomaly_threshold_file_V2 _Create Anomaly Threshold File V2_
 
     Run the command to create an anomaly threshold file
 
     Args:
-        path (string): 
-        host_id (int): 
-        service_id (int): 
-        metric_name (string): 
-        sensitivity (float): 
-        values (array): 
+        path (string):
+        host_id (int):
+        service_id (int):
+        metric_name (string):
+        sensitivity (float):
+        values (array):
 
     Example:
     | `Create Anomaly Threshold File V2` | /tmp/anomaly_threshold.json | 1 | 1 | metric_1 | 0.5 | ${values} |
 
     Returns: N/A
- 
-    """    
+
+    """
     f = open(path, "w")
     f.write("""[
     {{
@@ -3422,9 +3436,10 @@ def create_anomaly_threshold_file_V2(path: string, host_id: int, service_id: int
 """)
     f.close()
 
+
 def grep_retention(poller: int, pattern: str):
     """
-    
+
     grep_retention _Grep Retention_
 
     Run the command to grep retention.dat
@@ -3434,23 +3449,24 @@ def grep_retention(poller: int, pattern: str):
         pattern (str): pattern
 
     Returns: N/A
- 
-    """    
+
+    """
     return Common.grep("{}/log/centreon-engine/config{}/retention.dat".format(VAR_ROOT, poller), pattern)
 
+
 def modify_retention_dat(poller, host, service, key, value):
     """
-    
+
     modify_retention_dat _Modify Retention Dat_
 
     Run the command to modify a key in retention.dat
 
     Args:
-        poller (int): 
-        host (str): 
-        service (str): 
-        key (str): 
-        value (str): 
+        poller (int):
+        host (str):
+        service (str):
+        key (str):
+        value (str):
 
     Returns: N/A
 
@@ -3468,26 +3484,26 @@ def modify_retention_dat(poller, host, service, key, value):
         hst = ""
         svc = ""
         for i in range(len(lines)):
-            l = lines[i]
+            line = lines[i]
             if not in_block:
-                if l == "service {\n":
+                if line == "service {\n":
                     in_block = True
                     continue
             else:
-                if l == "}\n":
+                if line == "}\n":
                     in_block = False
                     hst = ""
                     svc = ""
                     continue
-                m = r_hst.match(l)
+                m = r_hst.match(line)
                 if m:
                     hst = m.group(1)
                     continue
-                m = r_svc.match(l)
+                m = r_svc.match(line)
                 if m:
                     svc = m.group(1)
                     continue
-                if l.startswith(f"{key}=") and host == hst and svc == service:
+                if line.startswith(f"{key}=") and host == hst and svc == service:
                     logger.console(f"key '{key}' found !")
                     lines[i] = f"{key}={value}\n"
                     hst = ""
@@ -3498,9 +3514,10 @@ def modify_retention_dat(poller, host, service, key, value):
         ff.writelines(lines)
         ff.close()
 
+
 def modify_retention_dat_host(poller, host, key, value):
     """
-    
+
     modify_retention_dat_host _Modify Retention Dat Host_
 
     Run the command to modify a key in retention.dat
@@ -3508,12 +3525,12 @@ def modify_retention_dat_host(poller, host, key, value):
     Args:
         poller (int): id of the chosen poller
         host (str): host_name
-        key (str): 
-        value (str): 
+        key (str):
+        value (str):
 
     Returns: N/A
 
-    """ 
+    """
     if host != "" and host != "":
         # We want a host
         ff = open(
@@ -3525,33 +3542,33 @@ def modify_retention_dat_host(poller, host, key, value):
         in_block = False
         hst = ""
         for i in range(len(lines)):
-            l = lines[i]
+            line = lines[i]
             if not in_block:
-                if l == "host {\n":
+                if line == "host {\n":
                     in_block = True
                     continue
             else:
-                if l == "}\n":
+                if line == "}\n":
                     in_block = False
                     hst = ""
                     continue
-                m = r_hst.match(l)
+                m = r_hst.match(line)
                 if m:
                     hst = m.group(1)
                     continue
-                if l.startswith(f"{key}=") and host == hst:
+                if line.startswith(f"{key}=") and host == hst:
                     logger.console(f"key '{key}' found !")
                     lines[i] = f"{key}={value}\n"
                     hst = ""
 
-        ff = open(
-            f"{VAR_ROOT}/log/centreon-engine/config{poller}/retention.dat", "w")
-        ff.writelines(lines)
-        ff.close()
+        with open(
+                f"{VAR_ROOT}/log/centreon-engine/config{poller}/retention.dat", "w") as ff:
+            ff.writelines(lines)
+
 
 def get_engine_process_stat(port, timeout=10):
     """
-    
+
     get_engine_process_stat _summary_
 
     Call the GetGenericStats function by gRPC it works with both engine and broker
@@ -3562,12 +3579,12 @@ def get_engine_process_stat(port, timeout=10):
 
     Returns:
         _type_: process__stat__pb2.pb_process_stat
-        
-    """    
+
+    """
     limit = time.time() + timeout
     while time.time() < limit:
         time.sleep(1)
-        with grpc.insecure_channel("127.0.0.1:{}".format(port)) as channel:
+        with grpc.insecure_channel(f"127.0.0.1:{port}") as channel:
             # same for engine and broker
             stub = engine_pb2_grpc.EngineStub(channel)
             try:
@@ -3578,9 +3595,10 @@ def get_engine_process_stat(port, timeout=10):
     logger.console("unable to get process stats")
     return None
 
+
 def send_bench(id: int, port: int):
     """
-    
+
     send_bench
 
     Run the command to send a bench event
@@ -3589,13 +3607,14 @@ def send_bench(id: int, port: int):
         id (int): field of the protobuf Bench message
         port (int): port of the grpc server
 
-    """    
+    """
     ts = Timestamp()
     ts.GetCurrentTime()
     with grpc.insecure_channel("127.0.0.1:{}".format(port)) as channel:
         stub = engine_pb2_grpc.EngineStub(channel)
         stub.SendBench(engine_pb2.BenchParam(id=id, ts=ts))
 
+
 def config_host_command_status(idx: int, cmd_name: str, status: int):
     filename = f"{ETC_ROOT}/centreon-engine/config{idx}/commands.cfg"
     with open(filename, "r") as f:
@@ -3612,7 +3631,7 @@ def config_host_command_status(idx: int, cmd_name: str, status: int):
         f.writelines(lines)
 
 
-def add_host_dependency(idx: int, host_name:str, dependent_host_name:str):
+def add_host_dependency(idx: int, host_name: str, dependent_host_name: str):
     """!
     add a host dependency in dependencies.cfg file
     @param idx index ofthe poller usually 0
@@ -3623,16 +3642,17 @@ def add_host_dependency(idx: int, host_name:str, dependent_host_name:str):
     with open(filename, "a+") as f:
         f.write(f"""
 define hostdependency {{
-    execution_failure_criteria     d,p 
+    execution_failure_criteria     d,p
     notification_failure_criteria  o,u
     dependency_period              24x7
-    inherits_parent                1 
-    dependent_host_name            {dependent_host_name} 
-    host_name                      {host_name} 
+    inherits_parent                1
+    dependent_host_name            {dependent_host_name}
+    host_name                      {host_name}
 }}
 """)
-        
-def add_service_dependency(idx: int, host_name:str, dependent_host_name:str, service:str, dependent_service:str):
+
+
+def add_service_dependency(idx: int, host_name: str, dependent_host_name: str, service: str, dependent_service: str):
     """!
     add a host dependency in dependencies.cfg file
     @param idx index ofthe poller usually 0
@@ -3645,15 +3665,13 @@ def add_service_dependency(idx: int, host_name:str, dependent_host_name:str, ser
     with open(filename, "a+") as f:
         f.write(f"""
 define servicedependency {{
-    execution_failure_criteria     c 
-    notification_failure_criteria  c 
-    inherits_parent                1 
+    execution_failure_criteria     c
+    notification_failure_criteria  c
+    inherits_parent                1
     dependency_period              24x7
-    dependent_host_name            {dependent_host_name} 
+    dependent_host_name            {dependent_host_name}
     host_name                      {host_name}
-    dependent_service_description  {dependent_service} 
-    service_description            {service} 
+    dependent_service_description  {dependent_service}
+    service_description            {service}
 }}
 """)
-
-