diff --git a/tests/resources/Broker.py b/tests/resources/Broker.py
index 460dd601473..abac5b0f370 100755
--- a/tests/resources/Broker.py
+++ b/tests/resources/Broker.py
@@ -420,6 +420,13 @@ def _apply_conf(name, callback):
 
 
 def config_broker(name, poller_inst: int = 1):
+    """
+    Configure a broker instance for test. Write the configuration files.
+
+    Args:
+        name (str): name of the conf broker wanted
+        poller_inst (int, optional): Defaults to 1.
+    """
     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)
@@ -470,6 +477,12 @@ def config_broker(name, poller_inst: int = 1):
 
 
 def change_broker_tcp_output_to_grpc(name: str):
+    """
+    Update broker configuration to use a gRPC output instead of a TCP one.
+
+    Args:
+        name (str): name of the conf broker wanted to be changed
+    """
     def output_to_grpc(conf):
         output_dict = conf["centreonBroker"]["output"]
         for i, v in enumerate(output_dict):
@@ -479,6 +492,14 @@ def output_to_grpc(conf):
 
 
 def add_path_to_rrd_output(name: str, path: str):
+    """
+    Set the path for the rrd output. If no rrd output is defined, this function
+    does nothing.
+
+    Args:
+        name (str): The broker instance name among central, rrd and module%d.
+        path (str): path to the rrd output.
+    """
     def rrd_output(conf):
         output_dict = conf["centreonBroker"]["output"]
         for i, v in enumerate(output_dict):
@@ -488,6 +509,13 @@ def rrd_output(conf):
 
 
 def change_broker_tcp_input_to_grpc(name: str):
+    """
+    Update the broker configuration to use gRPC input instead of a TCP one.
+    If no tcp input is found, no replacement is done.
+
+    Args:
+        name: The broker instance name among central, rrd and module%d.
+    """
     def input_to_grpc(conf):
         input_dict = conf["centreonBroker"]["input"]
         for i, v in enumerate(input_dict):
@@ -506,6 +534,18 @@ def add_broker_crypto(json_dict, add_cert: bool, only_ca_cert: bool):
 
 
 def add_broker_tcp_input_grpc_crypto(name: str, add_cert: bool, reversed: bool):
+    """
+    Add some crypto to broker gRPC input.
+
+    Args:
+        name: The broker instance name among central, rrd and module%d.
+        add_cert (bool): True to add a certificate, False otherwise.
+        reversed (bool): True if only a CA certificate is provided.
+
+    *Example:*
+
+    | Add Broker Tcp Input Grpc Crypto | central | ${True} | ${False} |
+    """
     def crypto_modifier(conf):
         input_dict = conf["centreonBroker"]["input"]
         for i, v in enumerate(input_dict):
@@ -515,6 +555,18 @@ def crypto_modifier(conf):
 
 
 def add_broker_tcp_output_grpc_crypto(name: str, add_cert: bool, reversed: bool):
+    """
+    Add grpc crypto to broker tcp output
+
+    Args:
+        name: The broker instance name among central, rrd and module%d.
+        add_cert (bool): True to add a certificate, False otherwise.
+        reversed (bool): False if only a we just want a CA certificate.
+
+     *Example:*
+
+    | Add Broker Tcp Output Grpc Crypto | module0 | ${True} | ${False} |
+    """
     def crypto_modifier(conf):
         input_dict = conf["centreonBroker"]["output"]
         for i, v in enumerate(input_dict):
@@ -524,6 +576,19 @@ def crypto_modifier(conf):
 
 
 def add_host_to_broker_output(name: str, output_name: str, host_ip: str):
+    """
+    Add a host to some broker output. This is useful for a grpc or tcp client
+    where we want where to connect to.
+
+    Args:
+        name (str): The broker instance name among central, rrd and module%d.
+        output_name (str): The name of the output to modify.
+        host_ip (str): the host address to set.
+
+    *Example:*
+
+    | Add Host To Broker Output | module0 | central-module-master-output | localhost |
+    """
     def modifier(conf):
         input_dict = conf["centreonBroker"]["output"]
         for i, v in enumerate(input_dict):
@@ -533,6 +598,19 @@ def modifier(conf):
 
 
 def add_host_to_broker_input(name: str, input_name: str, host_ip: str):
+    """
+    Add host to some broker input. This is useful for a grpc or tcp client
+    where we want to set where to connect to.
+
+    Args:
+        name: The broker instance name among central, rrd and module%d.
+        input_name (str): the name of the input to modify.
+        host_ip (str): the host address to set.
+
+    *Example:*
+
+    | Add Host To Broker Input | central | central-broker-master-input | localhost |
+    """
     def modifier(conf):
         input_dict = conf["centreonBroker"]["input"]
         for i, v in enumerate(input_dict):
@@ -542,6 +620,17 @@ def modifier(conf):
 
 
 def remove_host_from_broker_output(name: str, output_name: str):
+    """
+    Remove the host entry from a broker output given by its name.
+
+    Args:
+        name: The broker instance name among central, rrd and module%d.
+        output_name (str): The name of the output containing a host entry.
+
+    *Example:*
+
+    | Remove Host From Broker Output | module0 | central-module-master-output |
+    """
     def modifier(conf):
         input_dict = conf["centreonBroker"]["output"]
         for i, v in enumerate(input_dict):
@@ -551,6 +640,17 @@ def modifier(conf):
 
 
 def remove_host_from_broker_input(name: str, input_name: str):
+    """
+    Remove the host entry from a broker input given by its name.
+
+    Args:
+        name: The broker instance name among central, rrd and module%d.
+        input_name (str): The name of the input containing a host entry.
+
+    *Example:*
+
+    | Remove Host From Broker Input | central | central-broker-master-input |
+    """
     def modifier(conf):
         input_dict = conf["centreonBroker"]["input"]
         for i, v in enumerate(input_dict):
@@ -560,6 +660,18 @@ def modifier(conf):
 
 
 def change_broker_compression_output(config_name: str, output_name: str, compression_value: str):
+    """
+    Change the compression option of a broker output.
+
+    Args:
+        config_name (str): The broker instance name among central, rrd and module%d.
+        output_name (str): The output name to modify.
+        compression_value (str): The compression value. "yes/no", "1/0" or "true/false".
+
+    *Example:*
+
+    | Change Broker Compression Output | module0 | central-module-master-output | yes |
+    """
     def compression_modifier(conf):
         output_dict = conf["centreonBroker"]["output"]
         for i, v in enumerate(output_dict):
@@ -569,6 +681,18 @@ def compression_modifier(conf):
 
 
 def change_broker_compression_input(config_name: str, input_name: str, compression_value: str):
+    """
+    Change the compression option of a broker input.
+
+    Args:
+        config_name (str): The broker instance name among central, rrd and module%d.
+        input_name (str): The input name to modify.
+        compression_value (str): The compression value: "yes/no", "1/0" or "true/false".
+
+    *Example:*
+
+    | Change Broker Compression Input | central | central-broker-master-input | yes |
+    """
     def compression_modifier(conf):
         input_dict = conf["centreonBroker"]["input"]
         for i, v in enumerate(input_dict):
@@ -578,6 +702,23 @@ def compression_modifier(conf):
 
 
 def config_broker_bbdo_input(name, stream, port, proto, host=None):
+    """
+    Configure Broker BBDO input. It can be a client or a server. We provide a
+    port number and a protocol that is grpc or tcp.
+
+    Args:
+        name: The broker instance name among central, rrd and module%d.
+        stream: The type of stream among [bbdo_server, bbdo_client].
+        port: A port number.
+        proto: grpc or tcp.
+        host (str, optional): Defaults to None. Used to provide a host, needed
+        in the case of bbdo_client.
+
+    *Example:*
+
+    | Config Broker Bbdo Input | central | bbdo_server | 5669 | grpc | |
+    | Config Broker Bbdo Input | rrd | bbdo_client | 5670 | tcp | localhost |
+    """
     if stream != "bbdo_server" and stream != "bbdo_client":
         raise Exception(
             "config_broker_bbdo_input_output() function only accepts stream in ('bbdo_server', 'bbdo_client')")
@@ -614,6 +755,22 @@ def config_broker_bbdo_input(name, stream, port, proto, host=None):
 
 
 def config_broker_bbdo_output(name, stream, port, proto, host=None):
+    """
+    Configure Broker BBDO output. It can be a client or a server. We provide a
+    port number and a protocol that is grpc or tcp.
+
+    Args:
+        name: The broker instance name among central, rrd and module%d.
+        stream (str): The type of stream among [bbdo_server, bbdo_client].
+        port (int): A port number.
+        proto (str): grpc or tcp.
+        host (str, optional): Defaults to None. Used to provide a host to connect,
+        needed in the case of bbdo_client.
+
+    *Example:*
+
+    | Config Broker Bbdo Output | central | bbdo_client | 5670 | tcp | localhost |
+    """
     if stream != "bbdo_server" and stream != "bbdo_client":
         raise Exception(
             "config_broker_bbdo_output() function only accepts stream in ('bbdo_server', 'bbdo_client')")
@@ -650,6 +807,14 @@ def config_broker_bbdo_output(name, stream, port, proto, host=None):
 
 
 def config_broker_sql_output(name, output, queries_per_transaction: int = 20000):
+    """
+    Configure the broker sql output.
+
+    Args:
+        name (str): The broker instance name among central, rrd and module%d.
+        output (str): One string among "unified_sql" and "sql/perfdata".
+        queries_per_transaction (int, optional): Defaults to 20000.
+    """
     if name == 'central':
         filename = "central-broker.json"
     elif name.startswith('module'):
@@ -729,6 +894,18 @@ def config_broker_sql_output(name, output, queries_per_transaction: int = 20000)
 
 
 def broker_config_clear_outputs_except(name, ex: list):
+    """
+    Remove all the outputs of the broker configuration except those of types given
+    in the ex list.
+
+    Args:
+        name: The broker instance name among central, rrd and module%d.
+        ex (list): A list of type.
+
+    *Example:*
+
+    | Broker Config Clear Outputs Except | central | ["sql", "storage"] |
+    """
     if name == 'central':
         filename = "central-broker.json"
     elif name.startswith('module'):
@@ -751,6 +928,18 @@ def broker_config_clear_outputs_except(name, ex: list):
 
 
 def broker_config_add_item(name, key, value):
+    """
+    Add an item to the broker configuration
+
+    Args:
+        name (str): Which broker instance: central, rrd or module%d.
+        key (str): The key to add directly in the configuration first level.
+        value: The value.
+
+    *Example:*
+
+    | Broker Config Add Item | module0 | bbdo_version | 3.0.1 |
+    """
     if name == 'central':
         filename = "central-broker.json"
     elif name == 'rrd':
@@ -769,6 +958,17 @@ def broker_config_add_item(name, key, value):
 
 
 def broker_config_remove_item(name, key):
+    """
+    Remove an item from the broker configuration
+
+    Args:
+        name: The broker instance name among central, rrd and module%d
+        key: The key to remove. It must be defined at the first level of the configuration.
+
+    *Example:*
+
+    | Broker Config Remove Item | module0 | bbdo_version |
+    """
     if name == 'central':
         filename = "central-broker.json"
     elif name == 'rrd':
@@ -787,6 +987,18 @@ def broker_config_remove_item(name, key):
 
 
 def broker_config_add_lua_output(name, output, luafile):
+    """
+    Add a lua output to the broker configuration.
+
+    Args:
+        name (str): The broker instance name among central, rrd, module%d
+        output (str): The name of the Lua output.
+        luafile (str): The full name of the Lua script.
+
+    *Example:*
+
+    | Broker Config Add Lua Output | central | test-protobuf | /tmp/lua.lua |
+    """
     if name == 'central':
         filename = "central-broker.json"
     elif name.startswith('module'):
@@ -810,6 +1022,19 @@ def broker_config_add_lua_output(name, output, luafile):
 
 
 def broker_config_output_set(name, output, key, value):
+    """
+    Set an attribute value in a broker output.
+
+    Args:
+        name (str): The broker instance among central, rrd, module%d.
+        output (str): The output to work with.
+        key (str): The key whose value is to modify.
+        value (str): The new value to set.
+
+    *Example:*
+
+    | Broker Config Output Set | central | central-broker-master-sql | host | localhost |
+    """
     if name == 'central':
         filename = "central-broker.json"
     elif name.startswith('module'):
@@ -829,6 +1054,19 @@ def broker_config_output_set(name, output, key, value):
 
 
 def broker_config_output_set_json(name, output, key, value):
+    """
+    Set an attribute value in a broker output. The value is given as a json string.
+
+    Args:
+        name (str): The broker instance among central, rrd, module%d.
+        output (str): The output to work with.
+        key (str): The key whose value is to modify.
+        value (str): The new value to set.
+
+    *Example:*
+
+    | Broker Config Output Set Json | central | central-broker-master-sql | filters | {"category": ["neb", "foo", "bar"]} |
+    """
     if name == 'central':
         filename = "central-broker.json"
     elif name.startswith('module'):
@@ -849,6 +1087,18 @@ def broker_config_output_set_json(name, output, key, value):
 
 
 def broker_config_output_remove(name, output, key):
+    """
+    Remove a key from an output of the broker configuration.
+
+    Args:
+        name: The broker instance among central, rrd, module%d.
+        output: The output to work with.
+        key: The key to remove.
+
+    *Example:*
+
+    | Broker Config Output Remove | central | centreon-broker-master-rrd | host |
+    """
     if name == 'central':
         filename = "central-broker.json"
     elif name.startswith('module'):
@@ -869,6 +1119,19 @@ def broker_config_output_remove(name, output, key):
 
 
 def broker_config_input_set(name, inp, key, value):
+    """
+    Set an attribute in an input of a broker configuration.
+
+    Args:
+        name (str): The broker instance among central, rrd, module%d.
+        inp (str): The input to work with.
+        key (str): The key whose value is to modify.
+        value (str): The new value to set.
+
+    *Example:*
+
+    | Broker Config Input Set | rrd | rrd-broker-master-input | encryption | yes |
+    """
     if name == 'central':
         filename = "central-broker.json"
     elif name.startswith('module'):
@@ -888,6 +1151,14 @@ def broker_config_input_set(name, inp, key, value):
 
 
 def broker_config_input_remove(name, inp, key):
+    """
+    Remove a key from an input of the broker configuration.
+
+    Args:
+        name: The broker instance among central, rrd, module%d.
+        inp: The input to work with.
+        key: The key to remove.
+    """
     if name == 'central':
         filename = "central-broker.json"
     elif name.startswith('module'):
@@ -908,6 +1179,18 @@ def broker_config_input_remove(name, inp, key):
 
 
 def broker_config_log(name, key, value):
+    """
+    Configure broker log level.
+
+    Args:
+        name (str): The broker instance among central, rrd, module%d.
+        key (str): The logger name to modify.
+        value (str): The level among error, trace, info, debug, etc...
+
+    *Example:*
+
+    | Broker Config Log | central | bam | trace |
+    """
     if name == 'central':
         filename = "central-broker.json"
     elif name.startswith('module'):
@@ -926,6 +1209,17 @@ def broker_config_log(name, key, value):
 
 
 def broker_config_flush_log(name, value):
+    """
+    Configure the flush interval of the broker loggers. This value is in seconds, with 0, every logs are flushed.
+
+    Args:
+        name (str): the broker instance among central, rrd, module%d.
+        value (int): The value in seconds.
+
+    *Example:*
+
+    | Broker Config Flush Log | central | 1 |
+    """
     if name == 'central':
         filename = "central-broker.json"
     elif name.startswith('module'):
@@ -944,6 +1238,17 @@ def broker_config_flush_log(name, value):
 
 
 def broker_config_source_log(name, value):
+    """
+    Configure if logs should contain the source file and its line number.
+
+    Args:
+        name: The broker instance name among central, rrd and module%d.
+        value: A boolean that can be "true/false", "1/0" or "yes/no".
+
+    *Example:*
+
+    | Broker Config Source Log | central | 1 |
+    """
     if name == 'central':
         filename = "central-broker.json"
     elif name.startswith('module'):
@@ -962,6 +1267,23 @@ def broker_config_source_log(name, value):
 
 
 def check_broker_stats_exist(name, key1, key2, timeout=TIMEOUT):
+    """
+    Return True if the Broker stats file contain keys pair (key1,key2). key2 must
+    be a daughter key of key1.
+
+    Should be true if the poller is connected to the central broker.
+
+    Args:
+        name: The broker instance name among central, rrd and module%d.
+        key1 (str): A key at first level.
+        key2 (str): A key under the key1 key.
+        timeout (int, optional): . Defaults to TIMEOUT.
+
+    *Example:*
+
+    | ${exist} | Check Broker Stats Exist | mysql manager | poller | waiting tasks in connection 0 |
+    | Should Be True | ${exist} |
+    """
     limit = time.time() + timeout
     while time.time() < limit:
         if name == 'central':
@@ -989,6 +1311,18 @@ def check_broker_stats_exist(name, key1, key2, timeout=TIMEOUT):
 
 
 def get_broker_stats_size(name, key, timeout=TIMEOUT):
+    """
+    Return the number of items under the given key in the stats file.
+
+    Args:
+        name: The broker instance name among central, rrd and module%d.
+        key: The key to work with.
+        timeout (int, optional): Defaults to TIMEOUT = 30s.
+
+    *Example:*
+
+    | ${size} | Get Broker Stats Size | central | poller | # 2 |
+    """
     limit = time.time() + timeout
     retval = 0
     while time.time() < limit:
@@ -1022,13 +1356,16 @@ def get_broker_stats_size(name, key, timeout=TIMEOUT):
 
 
 def get_broker_stats(name: str, expected: str, timeout: int, *keys):
-    """!
-    read a value from broker stats
-    @param name central, module or rrd
-    @param expected: value expected (regexp)
-    @timeout delay to find key in stats
-    @param keys  keys in json stats output
-    @return True if value found and matches expected
+    """
+    Read a value from the broker stats file following the given keys. If the value is the expected one, return True.
+
+    Args:
+        name The broker instance to work with among central, module%d or rrd
+        expected: value expected (regexp)
+        timeout: duration in seconds after what the check fails.
+        keys: keys in json stats output
+
+    Returns: True if the expected value was found, otherwise it returns False.
     """
 
     def json_get(json_dict, keys: tuple, index: int):
@@ -1069,14 +1406,21 @@ def json_get(json_dict, keys: tuple, index: int):
     return False
 
 
-##
-# @brief Gets count indexes that does not exist in index_data.
-#
-# @param count:int The number of indexes to get.
-#
-# @return a list of index ids.
-#
 def get_not_existing_indexes(count: int):
+    """
+    Gets count indexes that does not exist in the centreon_storage.index_data table.
+
+    Args:
+        count (int): The number of indexes to get.
+
+    *Example:*
+
+    | @{indexes} | Get Not Existing Indexes | 10 |
+    | Log To Console | @{indexes} |
+
+    Returns:
+         a list of index IDs.
+    """
     # Connect to the database
     connection = pymysql.connect(host=DB_HOST,
                                  user=DB_USER,
@@ -1107,14 +1451,20 @@ def get_not_existing_indexes(count: int):
     return ids_db
 
 
-##
-# @brief Gets count indexes from available ones.
-#
-# @param count:int The number of indexes to get.
-#
-# @return a list of index ids.
-#
 def get_indexes_to_delete(count: int):
+    """
+    Gets count indexes from centreon_storage.index_data that really exist.
+
+    Args:
+        count (int): The number of indexes to get.
+
+    *Example:*
+
+    | @{indexes} | Get Not Existing Indexes | 10 |
+
+    Returns:
+        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]
@@ -1148,7 +1498,8 @@ def get_indexes_to_delete(count: int):
 
 
 def delete_all_rrd_metrics():
-    """! remove all rrd metrics files
+    """
+    Remove all rrd metrics files.
     """
     with os.scandir(VAR_ROOT + "/lib/centreon/metrics/") as it:
         for entry in it:
@@ -1157,12 +1508,19 @@ def delete_all_rrd_metrics():
 
 
 def check_rrd_info(metric_id: int, key: str, value, timeout: int = 60):
-    """!  execute rrdtool info and check one value of the returned informations
-    @param metric_id
-    @param key key to search in the rrdtool info result
-    @param value value to search in the rrdtool info result fot key
-    @param timeout  timeout for metric file creation
-    @return True if key = value found
+    """
+    Execute rrdtool info and check one value of the returned informations
+
+    Args:
+        metric_id (int): A metric ID.
+        key (str): The key whose value is to check.
+        value: The expected value.
+        timeout (int, optional): Defaults to 60.
+
+    *Example:*
+
+    | ${result} | Check Rrd Info | 1 | step | 60 |
+    | Should Be True | ${result} |
     """
 
     limit = time.time() + timeout
@@ -1180,11 +1538,23 @@ 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):
-    """! scan data base every 5s to extract metric ids for a service
+    """
+    Try to get the metric IDs of a service.
+
+    Warning:
+        A service is identified by a host ID and a service ID. This function should be used with caution.
+
+    Args:
+        service_id (int): The ID of the service.
+        metric_name (str, optional): Defaults to "%".
+        timeout (int, optional): Defaults to 60.
+
+    Returns:
+        A list of metric IDs or None if no metric found.
+
+    *Example:*
 
-    @param service_id id of the service
-    @param timeout  timeout in second
-    @return array of metric ids
+    | ${metrics} | Get Metrics For Service | 1 | % |
     """
     limit = time.time() + timeout
 
@@ -1211,14 +1581,20 @@ def get_metrics_for_service(service_id: int, metric_name: str = "%", timeout: in
     return None
 
 
-##
-# @brief Gets count metrics that does not exist.
-#
-# @param count:int The number of metrics to get.
-#
-# @return a list of metric ids.
-#
 def get_not_existing_metrics(count: int):
+    """
+    Return a list of metrics that does not exist.
+
+    Args:
+        count (int): How many metric IDs do we want.
+
+    Returns:
+        A list of IDs.
+
+    *Example:*
+
+    | @{metrics} | Get Not Existing Metrics | 10 |
+    """
     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]
@@ -1249,14 +1625,16 @@ def get_not_existing_metrics(count: int):
     return retval
 
 
-##
-# @brief Gets count metrics from available ones.
-#
-# @param count:int The number of metrics to get.
-#
-# @return a list of metric ids.
-#
 def get_metrics_to_delete(count: int):
+    """
+    Get count metrics from availables ones.
+
+    Args:
+        count (int): The number of metrics to get.
+
+    Returns:
+        A list of metric 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]
@@ -1281,12 +1659,13 @@ def get_metrics_to_delete(count: int):
     return inter[:count]
 
 
-##
-# @brief creat metrics from available ones.
-#
-# @param count:int The number of metrics to create.
-#
 def create_metrics(count: int):
+    """
+    Create count metrics from available ones.
+
+    Args:
+        count (int): How many metrics to create.
+    """
     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]
@@ -1330,6 +1709,14 @@ def create_metrics(count: int):
 
 
 def run_reverse_bam(duration, interval):
+    """
+    Launch the map_client.py script that simulates map.
+
+    Args:
+        duration: The duration in seconds before to stop map_client.py
+        interval: Interval given to the map_client.py that tells the duration
+                  between to recv calls.
+    """
     subp.Popen("broker/map_client.py {:f}".format(interval),
                shell=True, stdout=subp.PIPE, stdin=subp.PIPE)
     time.sleep(duration)
@@ -1337,17 +1724,36 @@ def run_reverse_bam(duration, interval):
 
 
 def start_map():
+    """
+    Launch the map_client_types.py script that simulates map.
+    """
     global map_process
     map_process = subp.Popen("broker/map_client_types.py",
                              shell=True, stdout=subp.DEVNULL, stdin=subp.DEVNULL)
 
 
 def clear_map_logs():
+    """
+    Reset the content of the /tmp/map-output.log file.
+    """
     with open('/tmp/map-output.log', 'w') as f:
         f.write("")
 
 
 def check_map_output(categories_str, expected_events, timeout: int = TIMEOUT):
+    """
+    Check the content of the /tmp/map-output.log file. This file contains informations on categories/elements of each
+    received event. A list of categories and event types are given to this function, so it can check if the file
+    contain these types of events. If it contains them, True is returned.
+
+    Args:
+        categories_str: A list of categories, for example ["1", "2"].
+        expected_events: A list of event types.
+        timeout (int, optional): A number of seconds, the default value is TIMEOUT.
+
+    Returns:
+        True on success, otherwise False.
+    """
     retval = False
     limit = time.time() + timeout
     while time.time() < limit:
@@ -1394,11 +1800,20 @@ def check_map_output(categories_str, expected_events, timeout: int = TIMEOUT):
 
 
 def get_map_output():
+    """
+    The map_client_types.py script writes on STDOUT. This function allows to get this output.
+
+    Returns:
+        A string containing the output.
+    """
     global map_process
     return map_process.communicate()[0]
 
 
 def stop_map():
+    """
+    Stop the script simulating map. Works with map_client_type.
+    """
     for proc in psutil.process_iter():
         if 'map_client_type' in proc.name():
             logger.console(
@@ -1420,13 +1835,17 @@ def stop_map():
     logger.console("map_client_type stopped")
 
 
-##
-# @brief Get count indexes that are available to rebuild them.
-#
-# @param count is the number of indexes to get.
-#
-# @return a list of indexes
 def get_indexes_to_rebuild(count: int, nb_day=180):
+    """
+    Get count indexes that are available to rebuild.
+
+    Args:
+        count (int): The number of indexes to get.
+        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]
@@ -1470,12 +1889,13 @@ def get_indexes_to_rebuild(count: int, nb_day=180):
     return retval
 
 
-##
-# @brief add a value at the mid of the first day of each metric
-#
-#
-# @return a list of indexes of pair <time of oldest value>, <metric id>
 def add_duplicate_metrics():
+    """
+    Add a value at the middle of the first day of each metric
+
+    Returns:
+        A list of indexes of pair <time of oldest value>, <metric id>
+    """
     connection = pymysql.connect(host=DB_HOST,
                                  user=DB_USER,
                                  password=DB_PASS,
@@ -1499,13 +1919,16 @@ def add_duplicate_metrics():
     return retval
 
 
-##
-# @brief check that metrics are not a NaN during one day
-#
-# @param an array of pair <time of oldest value>, <metric id> returned by add_duplicate_metrics
-#
-# @return true or false
 def check_for_NaN_metric(add_duplicate_metrics_ret):
+    """
+    Check that metrics are not a NaN during one day
+
+    Args:
+        add_duplicate_metrics_ret (): an array of pair <time of oldest value>, <metric id> returned by add_duplicate_metrics
+
+    Returns:
+        True on Success, otherwise False.
+    """
     for min_timestamp, metric_id in add_duplicate_metrics_ret:
         max_timestamp = min_timestamp + 86400
         res = getoutput(
@@ -1523,13 +1946,16 @@ def check_for_NaN_metric(add_duplicate_metrics_ret):
     return True
 
 
-##
-# @brief Returns metric ids matching the given indexes.
-#
-# @param indexes a list of indexes from index_data
-#
-# @return a list of metric ids.
 def get_metrics_matching_indexes(indexes):
+    """
+    Get metric IDs matching the given indexes.
+
+    Args:
+        indexes (list): a list of indexes from index_data.
+
+    Returns:
+        A list of metric IDs.
+    """
     # Connect to the database
     connection = pymysql.connect(host=DB_HOST,
                                  user=DB_USER,
@@ -1548,14 +1974,16 @@ def get_metrics_matching_indexes(indexes):
             return retval
 
 
-##
-# @brief send a gRPC command to remove graphs (by indexes or by metrics)
-#
-# @param port the gRPC port to use to send the command
-# @param indexes a list of indexes
-# @param metrics a list of metrics
-#
 def remove_graphs(port, indexes, metrics, timeout=10):
+    """
+    Send a gRPC command to remove graphs (by indexes or by metrics)
+
+    Args:
+        port (int): port the gRPC port to use to send the command
+        indexes (list): indexes a list of indexes
+        metrics (str): metrics a list of metrics
+        timeout (int, optional): Defaults to 10.
+    """
     limit = time.time() + timeout
     while time.time() < limit:
         time.sleep(1)
@@ -1572,6 +2000,16 @@ def remove_graphs(port, indexes, metrics, timeout=10):
 
 
 def broker_set_sql_manager_stats(port: int, stmt: int, queries: int, timeout=TIMEOUT):
+    """
+    Set values to the SQL manager stats: number of slowest statements and number
+    of slowest queries to keep in memory.
+
+    Args:
+        port: The gRPC port to use.
+        stmt: The number of slowest statements to keep in memory.
+        queries: The number of slowest queries to keep in memory.
+        timeout: A timeout in seconds, by default 30s.
+    """
     limit = time.time() + timeout
     while time.time() < limit:
         time.sleep(1)
@@ -1588,6 +2026,18 @@ def broker_set_sql_manager_stats(port: int, stmt: int, queries: int, timeout=TIM
 
 
 def broker_get_sql_manager_stats(port: int, query, timeout=TIMEOUT):
+    """
+    Tries to get some statistics about an SQL query. If that query makes part
+    of the slowest queries or statements, we get the average duration of it.
+
+    Args:
+        port: gRPC port to use.
+        query: An SQL query.
+        timeout: A timeout in seconds, by default 30s.
+
+    Returns:
+        A number of seconds or -1 on failure.
+    """
     limit = time.time() + timeout
     while time.time() < limit:
         time.sleep(1)
@@ -1614,13 +2064,15 @@ def broker_get_sql_manager_stats(port: int, query, timeout=TIMEOUT):
     return -1
 
 
-##
-# @brief send a query to the db to remove graphs (by indexes or by metrics)
-#
-# @param indexes a list of indexes
-# @param metrics a list of metrics
-#
 def remove_graphs_from_db(indexes, metrics, timeout=10):
+    """
+    Send a query to the db to remove graphs (by indexes or by metrics).
+
+    Args:
+        indexes (list): a list of indexes
+        metrics (list): a list of metrics
+        timeout (int, optional): Defaults to 10.
+    """
     logger.console("rem1")
     connection = pymysql.connect(host=DB_HOST,
                                  user=DB_USER,
@@ -1647,13 +2099,15 @@ def remove_graphs_from_db(indexes, metrics, timeout=10):
             connection.commit()
 
 
-##
-# @brief Execute the gRPC command RebuildRRDGraphs()
-#
-# @param port The port to use with gRPC.
-# @param indexes The list of indexes corresponding to metrics to rebuild.
-#
 def rebuild_rrd_graphs(port, indexes, timeout: int = TIMEOUT):
+    """
+    Execute the gRPC command RebuildRRDGraphs().
+
+    Args:
+        port (int): The port to use with gRPC
+        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:
@@ -1671,12 +2125,13 @@ def rebuild_rrd_graphs(port, indexes, timeout: int = TIMEOUT):
                 logger.console("gRPC server not ready")
 
 
-##
-# @brief Send a query to the db to rebuild graphs
-#
-# @param indexes The list of indexes corresponding to metrics to rebuild.
-#
 def rebuild_rrd_graphs_from_db(indexes):
+    """
+    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,
@@ -1695,15 +2150,17 @@ def rebuild_rrd_graphs_from_db(indexes):
                 connection.commit()
 
 
-##
-# @brief Compare the average value for an RRD metric on the last 30 days with
-# a value.
-#
-# @param metric The metric id
-# @param float The value to compare with.
-#
-# @return A boolean.
 def compare_rrd_average_value(metric, value: float):
+    """
+    Compare the average value for an RRD metric on the last 30 days with a value.
+
+    Args:
+        metric (int): The metric id
+        value (float): float The value to compare with.
+
+    Returns:
+        A boolean.
+    """
     res = getoutput("rrdtool graph dummy --start=end-180d --end=now"
                     " DEF:x=" + VAR_ROOT +
                     "/lib/centreon/metrics/{}.rrd:value:AVERAGE VDEF:xa=x,AVERAGE PRINT:xa:%lf"
@@ -1722,11 +2179,16 @@ def compare_rrd_average_value(metric, value: float):
 
 
 def compare_rrd_average_value_with_grpc(metric, key, value: float):
-    """! Compare the average value for an RRD metric.
-    @param metric The metric id
-    @param key The key to search in the rrd info
-    @param float The value to compare with.
-    @return True if value pointed by key is equal to value param.
+    """
+    Compare the average value for an RRD metric with a given value.
+
+    Args:
+        metric: The metric id
+        key: The key to search in the rrd info
+        value: The value to compare with.
+
+    Returns:
+        True if value pointed by key is equal to value param.
     """
     res = getoutput(
         f"rrdtool info {VAR_ROOT}/lib/centreon/metrics/{metric}.rrd"
@@ -1745,11 +2207,16 @@ def compare_rrd_average_value_with_grpc(metric, key, value: float):
 
 
 def check_sql_connections_count_with_grpc(port, count, timeout=TIMEOUT):
-    """!Call the GetSqlManagerStats function by gRPC and checks there are count active connections.
-    @param port grpc port
-    @param count number of expected connections
-    @param timeout timeout in seconds
-    @return  True is nb connections is equal to count
+    """
+    Call the GetSqlManagerStats function by gRPC and checks there are count active connections.
+
+    Args:
+        port: grpc port
+        count: number of expected connections
+        timeout: timeout in seconds
+
+    Returns:
+        True is nb connections is equal to count
     """
     limit = time.time() + timeout
     while time.time() < limit:
@@ -1773,14 +2240,17 @@ def check_sql_connections_count_with_grpc(port, count, timeout=TIMEOUT):
     return False
 
 
-##
-# @brief Call the GetSqlManagerStats function by gRPC and checks there are
-# count active connections.
-#
-# @param count The expected number of active connections.
-#
-# @return A boolean.
 def check_all_sql_connections_down_with_grpc(port, timeout=TIMEOUT):
+    """
+    Call the GetSqlManagerStats function by gRPC and checks there are count active connections.
+
+    Args:
+        port (int): The expected number of active connections.
+        timeout (int, optional): Defaults to TIMEOUT.
+
+    Returns:
+        A boolean.
+    """
     limit = time.time() + timeout
     while time.time() < limit:
         time.sleep(1)
@@ -1797,12 +2267,13 @@ def check_all_sql_connections_down_with_grpc(port, timeout=TIMEOUT):
     return False
 
 
-##
-# @brief Add the bam configuration to broker.
-#
-# @param name The broker name to consider.
-#
 def add_bam_config_to_broker(name):
+    """
+    Add the bam configuration to broker.
+
+    Args:
+        name (str): The broker name to consider.
+    """
     if name == 'central':
         filename = "central-broker.json"
     elif name.startswith('module'):
@@ -1851,15 +2322,17 @@ def add_bam_config_to_broker(name):
     f.write(json.dumps(conf, indent=2))
     f.close()
 
-##
-# @brief send a gRPC command to remove by name a poller
-#
-# @param port the gRPC port to use
-# @param name the poller name
-#
-
 
 def remove_poller(port, name, timeout=TIMEOUT):
+    """
+    Send a gRPC command to remove by name a poller.
+
+    Args:
+        port (int): the gRPC port to use
+        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}")
@@ -1874,15 +2347,16 @@ def remove_poller(port, name, timeout=TIMEOUT):
             except:
                 logger.console("gRPC server not ready")
 
-##
-# @brief send a gRPC command to remove by id a poller
-#
-# @param port the gRPC port to use
-# @param name the poller name
-#
-
 
 def remove_poller_by_id(port, idx, timeout=TIMEOUT):
+    """
+    Send a gRPC command to remove by id a poller
+
+    Args:
+        port (int): the gRPC port to use
+        idx (int): the poller name
+        timeout (int, optional): Defaults to TIMEOUT.
+    """
     limit = time.time() + timeout
     while time.time() < limit:
         logger.console(
@@ -1900,6 +2374,16 @@ def remove_poller_by_id(port, idx, timeout=TIMEOUT):
 
 
 def check_poller_disabled_in_database(poller_id: int, timeout: int):
+    """
+    Check if all the hosts monitored by a poller are disabled.
+
+    Args:
+        poller_id: The poller ID.
+        timeout: A timeout in seconds.
+
+    Returns:
+        True on success.
+    """
     limit = time.time() + timeout
     while time.time() < limit:
         connection = pymysql.connect(host=DB_HOST,
@@ -1921,6 +2405,16 @@ def check_poller_disabled_in_database(poller_id: int, timeout: int):
 
 
 def check_poller_enabled_in_database(poller_id: int, timeout: int):
+    """
+    Check if at least one host monitored by a poller is enabled.
+
+    Args:
+        poller_id: The poller ID.
+        timeout: A timeout in seconds.
+
+    Returns:
+        True on success.
+    """
     limit = time.time() + timeout
     while time.time() < limit:
         connection = pymysql.connect(host=DB_HOST,
@@ -1942,6 +2436,18 @@ def check_poller_enabled_in_database(poller_id: int, timeout: int):
 
 
 def get_broker_log_level(port, name, log, timeout=TIMEOUT):
+    """
+    Get the log level of a given logger. The timeout is due to the way we ask
+    for this information ; we use gRPC and the server may not be correctly
+    started.
+
+    Args:
+        port: The gRPC port to use.
+        log: The logger name.
+
+    Returns:
+        A string with the log level.
+    """
     limit = time.time() + timeout
     while time.time() < limit:
         logger.console("Try to call GetLogInfo")
@@ -1960,6 +2466,15 @@ def get_broker_log_level(port, name, log, timeout=TIMEOUT):
 
 
 def set_broker_log_level(port, name, log, level, timeout=TIMEOUT):
+    """
+    Set the log level of a given logger.
+
+    Args:
+        port: The gRPC port.
+        log: The name of the logger.
+        level: The level to set.
+        timeout: A timeout in seconds, 30s by default.
+    """
     limit = time.time() + timeout
     while time.time() < limit:
         logger.console("Try to call SetLogLevel")
@@ -1988,6 +2503,16 @@ def set_broker_log_level(port, name, log, level, timeout=TIMEOUT):
 
 
 def config_broker_remove_rrd_output(name):
+    """
+    Remove rrd output from  a broker configuration
+
+    Args:
+        name: The broker instance name among central, rrd and module%d.
+
+    *Example:*
+
+    | Config Broker Remove Rrd Output | central |
+    """
     if name == 'central':
         filename = "central-broker.json"
     elif name.startswith('module'):
@@ -2008,12 +2533,13 @@ def config_broker_remove_rrd_output(name):
         f.write(json.dumps(conf, indent=2))
 
 
-def broker_get_ba(port: int, ba_id: int, output_file:str, timeout=TIMEOUT):
+def broker_get_ba(port: int, ba_id: int, output_file: str, timeout=TIMEOUT):
     """
-    broker_get_ba calls the gRPC GetBa function provided by Broker.
+    Calls the gRPC GetBa function to create a dot file.
+
     Args:
-        port: the gRPC port
-        ba_id: The BA's ID we want to get.
+        port: the gRPC port to use.
+        ba_id: the BA's ID we want to get.
         output_file: The full path of the file to generate.
         timeout: A timeout in seconds (default value 30s).
 
diff --git a/tests/resources/Engine.py b/tests/resources/Engine.py
index c24d1488b99..5223c9b8b74 100755
--- a/tests/resources/Engine.py
+++ b/tests/resources/Engine.py
@@ -408,26 +408,25 @@ def create_template_file(poller: int, typ: str, what: str, ids):
     def create_tags(poller: int, nb: int, offset: int, tag_type: str):
         tt = ["servicegroup", "hostgroup", "servicecategory", "hostcategory"]
 
-        config_file = "{}/config{}/tags.cfg".format(CONF_DIR, poller)
-        ff = open(config_file, "w+")
-        content = ""
-        tid = 0
-        for i in range(nb):
-            if not tag_type:
-                 if i % 4 == 0:
-                     tid += 1
-                 typ = tt[i % 4]
-            else:
-                 typ = tag_type
-                 tid += 1
-            content += """define tag {{
-    id                     {0}
-    name                   tag{2}
-    type                   {1}
+        config_file = f"{CONF_DIR}/config{poller}/tags.cfg"
+        with open(config_file, "w+") as ff:
+            content = ""
+            tid = 0
+            for i in range(nb):
+                if len(tag_type) > 0:
+                    typ = tag_type
+                    tid += 1
+                else:
+                    if i % 4 == 0:
+                        tid += 1
+                    typ = tt[i % 4]
+                content += f"""define tag {{
+    id                     {tid}
+    tag_name               tag{i + offset}
+    type                   {typ}
 }}
-""".format(tid, typ, i + offset)
-        ff.write(content)
-        ff.close()
+"""
+            ff.write(content)
 
     def build_configs(self, hosts: int, services_by_host: int, debug_level=0):
         if exists(CONF_DIR):
@@ -658,31 +657,40 @@ def centengine_conf_add_anomaly(self):
         f.close()
 
 
-##
-# @brief Configure all the necessary files for num instances of centengine.
-#
-# @param num: How many engine configurations to start
-#
 def config_engine(num: int, hosts: int = 50, srv_by_host: int = 20):
+    """
+    Configure all the necessary files for num instances of centengine.
+
+    Args:
+        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)
 
 
-##
-# @brief Accessor to the number of centengine configurations
-#
 def get_engines_count():
+    """
+    Return the number of centengine configurations.
+
+    Returns:
+        The number of running centengine instances
+    """
     return engine.instances
 
 
-##
-# @brief Function to change a value in the centengine.cfg for the config idx.
-#
-# @param idx index of the configuration (from 0)
-# @param key the key to change the value.
-# @param value the new value to set to the key variable.
-#
 def engine_config_set_value(idx: int, key: str, value: str, force: bool = False):
+    """
+    Set a value in the centengine.cfg
+
+    Args:
+        idx (int): Index of the Engine configuration (from 0)
+        key (str): the key whose value needs to change.
+        value (str): the new value to set.
+        force (bool, optional): Defaults to False. If the key doesn't exist in the configuration, and force is set to
+        true, the key will be added to the file.
+    """
     filename = ETC_ROOT + \
         "/centreon-engine/config{}/centengine.cfg".format(idx)
     f = open(filename, "r")
@@ -702,16 +710,17 @@ def engine_config_set_value(idx: int, key: str, value: str, force: bool = False)
     f.writelines(lines)
     f.close()
 
-##
-# @brief Function to add a value in the centengine.cfg for the config idx.
-#
-# @param idx index of the configuration (from 0)
-# @param key the key to change the value.
-# @param value the new value to set to the key variable.
-#
+def engine_config_add_value(idx: int, key: str, value: str):
+    """
+    engine_config_add_value _Engine Config Add Value_
 
+    Run a command to add a value in the centengine.cfg for the config idx.
 
-def engine_config_add_value(idx: int, key: str, value: str):
+    Args:
+        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 = ETC_ROOT + \
         "/centreon-engine/config{}/centengine.cfg".format(idx)
     f = open(filename, "a")
@@ -719,15 +728,16 @@ def engine_config_add_value(idx: int, key: str, value: str):
     f.close()
 
 
-##
-# @brief Function to change a value in the services.cfg for the config idx.
-#
-# @param idx index of the configuration (from 0)
-# @param desc service description of the service to modify.
-# @param key the key to change the value.
-# @param value the new value to set to the key variable.
-#
 def engine_config_set_value_in_services(idx: int, desc: str, key: str, value: str):
+    """
+    Set a parameter in the services.cfg.
+
+    Args:
+        idx (int): Index of the centengine configuration (from 0).
+        desc (str): Service description of the service to modify.
+        key (str): The key whose value needs to change.
+        value (str): The new value to set.
+    """
     filename = ETC_ROOT + "/centreon-engine/config{}/services.cfg".format(idx)
     f = open(filename, "r")
     lines = f.readlines()
@@ -743,11 +753,14 @@ def engine_config_set_value_in_services(idx: int, desc: str, key: str, value: st
     f.close()
 
 def engine_config_replace_value_in_services(idx: int, desc: str, key: str, value: str):
-    """! Function to update a value in the services.cfg for the config idx.
-    @param idx index of the configuration (from 0)
-    @param desc service description of the service to modify.
-    @param key the key to change the value.
-    @param value the new value to set to the key variable.
+    """
+    Changes the value of a parameter in the services.cfg file for the centengine number idx.
+
+    Args:
+        idx (int): Index of the configuration (from 0)
+        desc (str): Service description of the service to modify.
+        key (str): Name of the parameter to change.
+        value (str): New value to set.
     """
 
     filename = f"{ETC_ROOT}/centreon-engine/config{idx}/services.cfg"
@@ -766,17 +779,16 @@ def engine_config_replace_value_in_services(idx: int, desc: str, key: str, value
     with open(filename, "w") as f:
         f.writelines(lines)
 
-##
-# @brief Function to change a value in the hosts.cfg for the config idx.
-#
-# @param idx index of the configuration (from 0)
-# @param desc host name of the host to modify.
-# @param key the key to change the value.
-# @param value the new value to set to the key variable.
-#
-
-
 def engine_config_set_value_in_hosts(idx: int, desc: str, key: str, value: str):
+    """
+    Set a parameter in the hosts.cfg for the Engine configuration idx.
+
+    Args:
+        idx (int): Index of the Engine configuration (from 0)
+        desc (str): host name of the host to modify.
+        key (str): the parameter whose value has to change.
+        value (str): the value to set.
+    """
     filename = ETC_ROOT + "/centreon-engine/config{}/hosts.cfg".format(idx)
     f = open(filename, "r")
     lines = f.readlines()
@@ -792,14 +804,15 @@ def engine_config_set_value_in_hosts(idx: int, desc: str, key: str, value: str):
     f.close()
 
 
-##
-# @brief Function to change a value in the commands.cfg for the config idx.
-#
-# @param idx index of the configuration (from 0)
-# @param command_index  index of the command (may be a regex)
-# @param new_command
-#
 def engine_config_change_command(idx: int, command_index: str, new_command: str):
+    """
+    Changes the command line of command whose index is command_index in the Engine config idx.
+
+    Args:
+        idx (int): Index of the configuration (from 0)
+        command_index (str): Index of the command (may be a regex)
+        new_command (str): The new command line.
+    """
     f = open(f"{CONF_DIR}/config{idx}/commands.cfg", "r")
     lines = f.readlines()
     f.close
@@ -820,14 +833,16 @@ def engine_config_change_command(idx: int, command_index: str, new_command: str)
     f.close
 
 
-##
-# @brief Function to add a new command in the commands.cfg for the config idx
-#
-# @param idx index of the configuration (from 0)
-# @param command_name
-# @param new_command
-#
 def engine_config_add_command(idx: int, command_name: str, new_command: str):
+    """
+    Add a new command in the commands.cfg for the Engine config idx.
+
+    Args:
+        idx (int): Index of the Engine configuration (from 0)
+        command_name (str): Command name
+        new_command (str): Command line
+        connector (str, optional): Defaults to None.
+    """
     f = open(f"{CONF_DIR}/config{idx}/commands.cfg", "a")
     f.write("""define command {{
     command_name                   {} 
@@ -844,6 +859,15 @@ def engine_config_add_command(idx: int, command_name: str, new_command: str):
 # @param value the new value to set to the key variable.
 #
 def engine_config_set_value_in_contacts(idx: int, desc: str, key: str, value: str):
+    """
+    Modify a parameter in the contacts.cfg for the Engine config idx.
+
+    Args:
+        idx (int): Index of the configuration (from 0)
+        desc (str): Contact name
+        key (str): The parameter whose value must change.
+        value (str): The new value to set.
+    """
     filename = f"{ETC_ROOT}/centreon-engine/config{idx}/contacts.cfg"
     f = open(filename, "r")
     lines = f.readlines()
@@ -861,6 +885,15 @@ def engine_config_set_value_in_contacts(idx: int, desc: str, key: str, value: st
 
 
 def engine_config_set_value_in_escalations(idx: int, desc: str, key: str, value: str):
+    """
+    Replace a value in the escalations.cfg for the config idx
+
+    Args:
+        idx (int): Index of the Engine configuration (from 0)
+        desc (str): Escalation name
+        key (str): the parameter whose value must change.
+        value (str): the new value to set.
+    """
     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*$")
@@ -872,6 +905,13 @@ def engine_config_set_value_in_escalations(idx: int, desc: str, key: str, value:
         ff.writelines(lines)
 
 def engine_config_remove_service_host(idx: int, host: str):
+    """
+    Remove all the services of a host from the services.cfg file.
+
+    Args:
+        idx (int): index of the configuration (from 0)
+        host (str): Host name
+    """
     filename = ETC_ROOT + "/centreon-engine/config{}/services.cfg".format(idx)
     f = open(filename, "r")
     lines = f.readlines()
@@ -903,6 +943,13 @@ def engine_config_remove_service_host(idx: int, host: str):
 
 
 def engine_config_remove_host(idx: int, host: str):
+    """
+    Remove a host from the hosts.cfg configuration file.
+
+    Args:
+        idx (int): Index of the configuration (from 0)
+        host (str): name of the host wanted to be removed
+    """
     filename = f"{ETC_ROOT}/centreon-engine/config{idx}/hosts.cfg"
     with open(filename, "r") as f:
         lines = f.readlines()
@@ -934,6 +981,14 @@ def engine_config_remove_host(idx: int, host: str):
 
 
 def add_host_group(index: int, id_host_group: int, members: list):
+    """
+    Add a host group on the engine instance index
+
+    Args:
+        index (int): index of the configuration (from 0)
+        id_host_group (int): ID of the new host group to add.
+        members (list): A list of host names.
+    """
     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)
@@ -942,6 +997,18 @@ def add_host_group(index: int, id_host_group: int, members: list):
 
 
 def rename_host_group(index: int, id_host_group: int, name: str, members: list):
+    """
+    Rename a host group on the engine instance index. It also modifies its members.
+
+    Warning:
+        This function changes the configuration file but not the internal configuration. It can lead to conflicts.
+
+    Args:
+        index (int): index of the configuration (from 0)
+        id_host_group (int): Host group ID.
+        name (str): host_group_name
+        members (list): The new list of host members.
+    """
     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)
@@ -956,6 +1023,15 @@ def rename_host_group(index: int, id_host_group: int, name: str, members: list):
 
 
 def rename_service(index: int, hst: str, svc: str, new_svc: str):
+    """
+    Rename a service on the engine instance index.
+
+    Args:
+        index (int): Index of the configuration(from 0).
+        hst (str): The host containing the service.
+        svc (str): The description of the service.
+        new_svc (str): The new description of the service.
+    """
     f = open(f"{ETC_ROOT}/centreon-engine/config{index}/services.cfg", "r")
     ll = f.readlines()
     f.close()
@@ -996,6 +1072,14 @@ def rename_service(index: int, hst: str, svc: str, new_svc: str):
 
 
 def add_service_group(index: int, id_service_group: int, members: list):
+    """
+    Add a service group on the engine instance index.
+
+    Args:
+        index (int): index of the configuration (from 0)
+        id_service_group (int): ID of the new service group.
+        members (list): A list of its members.
+    """
     f = open(
         ETC_ROOT + "/centreon-engine/config{}/servicegroups.cfg".format(index), "a+")
     logger.console(members)
@@ -1003,11 +1087,33 @@ def add_service_group(index: int, id_service_group: int, members: list):
     f.close()
 
 def add_contact_group(index: int, id_contact_group: int, members: list):
+    """
+    Add a contact group on the engine instance index.
+
+    Args:
+        index (int): Index of the poller configuration (from 0).
+        id_contact_group (int): ID of new contactgroup.
+        members (list): A list of the members (by name).
+    """
     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))
 
 def create_service(index: int, host_id: int, cmd_id: int):
+    """
+    Create a service on the engine instance index, on the host host_id, with the command cmd_id.
+
+    Args:
+        index (int): Index of the poller configuration (from 0).
+        host_id (int): The host ID of the new service to create.
+        cmd_id (int): The command ID this new service has to use.
+
+    Returns:
+        A service ID.
+
+    Example:
+    | ${svc_id} | Create Service | 0 | 1 | 1 |
+    """
     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')
@@ -1025,6 +1131,19 @@ def create_service(index: int, host_id: int, cmd_id: int):
 
 
 def create_anomaly_detection(index: int, host_id: int, dependent_service_id: int, metric_name: string, sensitivity: float = 0.0):
+    """
+    Create an anomaly detection on the engine instance with the given index.
+
+    Args:
+        index (int): index of the Engine configuration (from 0)
+        host_id (int): ID of the host containing the new anomaly detection.
+        dependent_service_id (int): ID of the dependent service linked to the new anomaly detection.
+        metric_name (string): The service metric name used for the anomaly detection.
+        sensitivity (float, optional): Defaults to 0.0.
+
+    Returns:
+        The ID of the new anomaly detection.
+    """
     f = open(
         ETC_ROOT + "/centreon-engine/config{}/anomaly_detection.cfg".format(index), "a+")
     to_append = engine.create_anomaly_detection(
@@ -1044,55 +1163,128 @@ def create_anomaly_detection(index: int, host_id: int, dependent_service_id: int
     return retval
 
 
-def engine_log_duplicate(result: list):
-    dup = True
-    for i in result:
-        if (i[0] % 2) != 0:
-            dup = False
-    return dup
-
-
 def clone_engine_config_to_db():
+    """
+    Clone all the Engine configurations to the database. In other words, create
+    the current configuration in the centreon database.
+    """
     global dbconf
     dbconf = db_conf.DbConf(engine)
     dbconf.create_conf_db()
 
 
 def add_bam_config_to_engine():
+    """
+    Add the bam configuration to the Engine.
+    """
     global dbconf
     dbconf.init_bam()
 
 
 def create_ba_with_services(name: str, typ: str, svc: list, dt_policy="inherit"):
+    """
+    Create a BA with the given services.
+
+    Args:
+        name (str): name of the ba
+        typ (str): type of the ba: worst, best, ratio_percent, ratio_number, impact.
+        svc (list): services name chosen to create the ba.
+        dt_policy (str, optional): Defaults to "inherit": inherit, ignore, ignore_all.
+
+    Returns:
+        A tuple(BA ID, virtual service associated to the BA).
+    """
     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 a BA.
+
+    Args:
+        name (str): the BA name.
+        typ (str): The type of the ba (worst,best,impact, ...)
+        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
+        dt_policy (str, optional): Defaults to "inherit": inherit, ignore, ignore_all
+
+    Returns:
+        A tuple(BA ID, virtual service associated to the BA).
+    """
     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 a boolean KPI to a BA.
+
+    Args:
+        id_ba (int): The BA ID.
+        expression (str): An expression.
+        impact_if (bool): (true/false)
+        critical_impact (int): Impact weight in the event of a Critical condition, in real-time monitoring
+
+    Returns:
+        The ID of the boolean expression.
+    """
     return dbconf.add_boolean_kpi(id_ba, expression, impact_if, critical_impact)
 
 
 def update_boolean_rule(boolean_id: int, expression: str):
+    """
+    Udpate a boolean rule.
+
+    Args:
+        boolean_id (int): The ID of the boolean expression to change.
+        expression (str): The new expression.
+    """
     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 a BA KPI.
+
+    Args:
+        id_ba_src (int): The ID of the daughter BA.
+        id_ba_dest (int): The ID of the mother BA.
+        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
+    """
     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 a service KPI.
+
+    Args:
+        host (str): Host name of the host containing the service.
+        serv (str): Service description of the service.
+        id_ba (int): ID of the parent BA of the service KPI.
+        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
+    """
     global dbconf
     dbconf.add_service_kpi(
         host, serv, id_ba, critical_impact, warning_impact, unknown_impact)
 
 
 def get_command_id(service: int):
+    """
+    Get the command ID of the service with the given ID.
+
+    Args:
+        service (int): ID of the service containing the command
+
+    Returns:
+        The command ID.
+    """
     global engine
     global dbconf
     cmd_name = engine.service_cmd[service]
@@ -1100,11 +1292,29 @@ def get_command_id(service: int):
 
 
 def get_command_service_param(service: int):
+    """
+    Get the command service param of a service.
+
+    Args:
+        service (int): ID of the service.
+
+    Returns:
+        A string containing the arguments given to the command for that service.
+    """
     global engine
     return engine.service_cmd[service][8:]
 
 
 def change_normal_svc_check_interval(use_grpc: int, hst: str, svc: str, check_interval: int):
+    """
+    Update the normal check interval for a service.
+
+    Args:
+        use_grpc (int): If not zero, the action is made by gRPC, otherwise it is done with a legacy command.
+        hst (str): Host name of host containing the service.
+        svc (str): Service description.
+        check_interval (int): new check interval in seconds.
+    """
     if use_grpc > 0:
         with grpc.insecure_channel("127.0.0.1:50001") as channel:
             stub = engine_pb2_grpc.EngineStub(channel)
@@ -1120,6 +1330,14 @@ def change_normal_svc_check_interval(use_grpc: int, hst: str, svc: str, check_in
 
 
 def change_normal_host_check_interval(use_grpc: int, hst: str, check_interval: int):
+    """
+    Update the normal check interval for a host.
+
+    Args:
+        use_grpc (int): if not zero by grpc, otherwise using legacy commands.
+        hst (str): host name.
+        check_interval (int): new check interval in seconds.
+    """
     if use_grpc > 0:
         with grpc.insecure_channel("127.0.0.1:50001") as channel:
             stub = engine_pb2_grpc.EngineStub(channel)
@@ -1135,6 +1353,15 @@ def change_normal_host_check_interval(use_grpc: int, hst: str, check_interval: i
 
 
 def change_retry_svc_check_interval(use_grpc: int, hst: str, svc: str, retry_interval: int):
+    """
+    Change the retry check interval of a service.
+
+    Args:
+        use_grpc (int): if not zero by grpc, otherwise with legacy commands.
+        hst (str): Host name of the service.
+        svc (str): Description of the service.
+        retry_interval (int): New retry interval in seconds.
+    """
     if use_grpc > 0:
         with grpc.insecure_channel("127.0.0.1:50001") as channel:
             stub = engine_pb2_grpc.EngineStub(channel)
@@ -1150,6 +1377,14 @@ def change_retry_svc_check_interval(use_grpc: int, hst: str, svc: str, retry_int
 
 
 def change_retry_host_check_interval(use_grpc: int, hst: str, retry_interval: int):
+    """
+    Change the retry check interval for a host.
+
+    Args:
+        use_grpc (int): If not zero by gRPC, otherwise with legacy commands.
+        hst (str): Host name of the concerned host.
+        retry_interval (int): New retry interval in seconds.
+    """
     if use_grpc > 0:
         with grpc.insecure_channel("127.0.0.1:50001") as channel:
             stub = engine_pb2_grpc.EngineStub(channel)
@@ -1165,6 +1400,15 @@ def change_retry_host_check_interval(use_grpc: int, hst: str, retry_interval: in
 
 
 def change_max_svc_check_attempts(use_grpc: int, hst: str, svc: str, max_check_attempts: int):
+    """
+    Change the max check attempts for a service.
+
+    Args:
+        use_grpc (int): If not zero by gRPC, otherwise with legacy commands.
+        hst (str): host name of the service.
+        svc (str): service description.
+        max_check_attempts (int): number of max check attempts wanted.
+    """
     if use_grpc > 0:
         with grpc.insecure_channel("127.0.0.1:50001") as channel:
             stub = engine_pb2_grpc.EngineStub(channel)
@@ -1180,6 +1424,14 @@ def change_max_svc_check_attempts(use_grpc: int, hst: str, svc: str, max_check_a
 
 
 def change_max_host_check_attempts(use_grpc: int, hst: str, max_check_attempts: int):
+    """
+    Change the max check attempts of a host.
+
+    Args:
+        use_grpc (int): If not zero by gRPC, otherwise with legacy commands.
+        hst (str): Host name.
+        max_check_attempts (int): number of max check attempts wanted.
+    """
     if use_grpc > 0:
         with grpc.insecure_channel("127.0.0.1:50001") as channel:
             stub = engine_pb2_grpc.EngineStub(channel)
@@ -1195,6 +1447,14 @@ def change_max_host_check_attempts(use_grpc: int, hst: str, max_check_attempts:
 
 
 def change_host_check_timeperiod(use_grpc: int, hst: str, check_timeperiod: str):
+    """
+    Change the check timeperiod for a host.
+
+    Args:
+        use_grpc (int): If not zero by gRPC, otherwise with legacy commands.
+        hst (str): host name.
+        check_timeperiod (str): check time period to set (examples: 24x7, 24x6, workhours..).
+    """
     if use_grpc > 0:
         with grpc.insecure_channel("127.0.0.1:50001") as channel:
             stub = engine_pb2_grpc.EngineStub(channel)
@@ -1210,6 +1470,14 @@ def change_host_check_timeperiod(use_grpc: int, hst: str, check_timeperiod: str)
 
 
 def change_host_notification_timeperiod(use_grpc: int, hst: str, notification_timeperiod: str):
+    """
+    Change the host notification timeperiod for a given host.
+
+    Args:
+        use_grpc (int): If not zero by gRPC, otherwise with legacy commands.
+        hst (str):  host name of the concerned host.
+        notification_timeperiod (str): notification check period (24x7, 24x6, workhours..)
+    """
     if use_grpc > 0:
         with grpc.insecure_channel("127.0.0.1:50001") as channel:
             stub = engine_pb2_grpc.EngineStub(channel)
@@ -1225,6 +1493,15 @@ def change_host_notification_timeperiod(use_grpc: int, hst: str, notification_ti
 
 
 def change_svc_check_timeperiod(use_grpc: int, hst: str, svc: str, check_timeperiod: str):
+    """
+    Change the service check timeperiod for a service.
+
+    Args:
+        use_grpc (int): If not zero by gRPC, otherwise with legacy commands.
+        hst (str): host name of the service.
+        svc (str): service description of the service.
+        check_timeperiod (str): check period (24x7, 24x6, workhours..)
+    """
     if use_grpc > 0:
         with grpc.insecure_channel("127.0.0.1:50001") as channel:
             stub = engine_pb2_grpc.EngineStub(channel)
@@ -1240,6 +1517,15 @@ def change_svc_check_timeperiod(use_grpc: int, hst: str, svc: str, check_timeper
 
 
 def change_svc_notification_timeperiod(use_grpc: int, hst: str, svc: str, notification_timeperiod: str):
+    """
+    Change the notification timeperiod for a service.
+
+    Args:
+        use_grpc (int): If not zero by gRPC, otherwise with legacy commands.
+        hst (str): Host name of the service.
+        svc (str): Service description of the service.
+        notification_timeperiod (str): Notification timeperiod (24x7, 24x6, workhours..)
+    """
     if use_grpc > 0:
         with grpc.insecure_channel("127.0.0.1:50001") as channel:
             stub = engine_pb2_grpc.EngineStub(channel)
@@ -1255,6 +1541,13 @@ def change_svc_notification_timeperiod(use_grpc: int, hst: str, svc: str, notifi
 
 
 def disable_host_and_child_notifications(use_grpc: int, hst: str):
+    """
+    Disable all the notifications on a host (the host itself and its children).
+
+    Args:
+        use_grpc (int): If not zero by gRPC, otherwise with legacy commands.
+        hst (str): Host name of the concerned host.
+    """
     if use_grpc > 0:
         with grpc.insecure_channel("127.0.0.1:50001") as channel:
             stub = engine_pb2_grpc.EngineStub(channel)
@@ -1270,6 +1563,13 @@ def disable_host_and_child_notifications(use_grpc: int, hst: str):
 
 
 def enable_host_and_child_notifications(use_grpc: int, hst: str):
+    """
+    Enable all the notifications on a host (the host itself and its children).
+
+    Args:
+        use_grpc (int): If not zero by gRPC, otherwise with legacy commands.
+        hst (str): Host name of the concerned host.
+    """
     if use_grpc > 0:
         with grpc.insecure_channel("127.0.0.1:50001") as channel:
             stub = engine_pb2_grpc.EngineStub(channel)
@@ -1285,6 +1585,13 @@ def enable_host_and_child_notifications(use_grpc: int, hst: str):
 
 
 def disable_host_check(use_grpc: int, hst: str):
+    """
+    Disable checks on a given host.
+
+    Args:
+        use_grpc (int): If not zero by gRPC, otherwise with legacy commands.
+        hst (str): host name of the concerned host.
+    """
     if use_grpc == 0:
         now = int(time.time())
         cmd = "[{}] DISABLE_HOST_CHECK;{}\n".format(
@@ -1295,6 +1602,13 @@ def disable_host_check(use_grpc: int, hst: str):
 
 
 def enable_host_check(use_grpc: int, hst: str):
+    """
+    Enable checks on a given host.
+
+    Args:
+        use_grpc (int): If not zero by gRPC, otherwise with legacy commands.
+        hst (str): host name of the concerned host.
+    """
     if use_grpc == 0:
         now = int(time.time())
         cmd = "[{}] ENABLE_HOST_CHECK;{}\n".format(
@@ -1305,6 +1619,13 @@ def enable_host_check(use_grpc: int, hst: str):
 
 
 def disable_host_event_handler(use_grpc: int, hst: str):
+    """
+    Disable a host event handler.
+
+    Args:
+        use_grpc (int): If not zero by gRPC, otherwise with legacy commands.
+        hst (str): host name of the concerned host.
+    """
     if use_grpc == 0:
         now = int(time.time())
         cmd = "[{}] DISABLE_HOST_EVENT_HANDLER;{}\n".format(
@@ -1315,6 +1636,13 @@ def disable_host_event_handler(use_grpc: int, hst: str):
 
 
 def enable_host_event_handler(use_grpc: int, hst: str):
+    """
+    Enable a host event handler.
+
+    Args:
+        use_grpc (int): If not zero by gRPC, otherwise with legacy commands.
+        hst (str): host name of the concerned host.
+    """
     if use_grpc == 0:
         now = int(time.time())
         cmd = "[{}] ENABLE_HOST_EVENT_HANDLER;{}\n".format(
@@ -1325,6 +1653,13 @@ def enable_host_event_handler(use_grpc: int, hst: str):
 
 
 def disable_host_flap_detection(use_grpc: int, hst: str):
+    """
+    Disable the flap detection on a host.
+
+    Args:
+        use_grpc (int): If not zero by gRPC, otherwise with legacy commands.
+        hst (str): host name of the concerned host.
+    """
     if use_grpc == 0:
         now = int(time.time())
         cmd = "[{}] DISABLE_HOST_FLAP_DETECTION;{}\n".format(
@@ -1335,6 +1670,13 @@ def disable_host_flap_detection(use_grpc: int, hst: str):
 
 
 def enable_host_flap_detection(use_grpc: int, hst: str):
+    """
+    Enable the flap detection on a host.
+
+    Args:
+        use_grpc (int): If not zero by gRPC, otherwise with legacy commands.
+        hst (str): host name of the concerned host.
+    """
     if use_grpc == 0:
         now = int(time.time())
         cmd = "[{}] ENABLE_HOST_FLAP_DETECTION;{}\n".format(
@@ -1345,6 +1687,13 @@ def enable_host_flap_detection(use_grpc: int, hst: str):
 
 
 def disable_host_notifications(use_grpc: int, hst: str):
+    """
+    Disable the notifications on a host.
+
+    Args:
+        use_grpc (int): If not zero by gRPC, otherwise with legacy commands.
+        hst (str): host name of the concerned host.
+    """
     if use_grpc > 0:
         with grpc.insecure_channel("127.0.0.1:50001") as channel:
             stub = engine_pb2_grpc.EngineStub(channel)
@@ -1360,6 +1709,13 @@ def disable_host_notifications(use_grpc: int, hst: str):
 
 
 def enable_host_notifications(use_grpc: int, hst: str):
+    """
+    Enable notifications on a host.
+
+    Args:
+        use_grpc (int): If not zero by gRPC, otherwise with legacy commands.
+        hst (str): host name of the concerned host.
+    """
     if use_grpc > 0:
         with grpc.insecure_channel("127.0.0.1:50001") as channel:
             stub = engine_pb2_grpc.EngineStub(channel)
@@ -1375,6 +1731,15 @@ def enable_host_notifications(use_grpc: int, hst: str):
 
 
 def update_ano_sensitivity(use_grpc: int, hst: str, serv: str, sensitivity: float):
+    """
+    Update the anomaly detection sensitivity of an anomalydetection.
+
+    Args:
+        use_grpc (int): If not zero by gRPC, otherwise with legacy commands.
+        hst (str):  host name of the anomalydetection.
+        serv (str): service description of the anomalydetection.
+        sensitivity (float): the new sensivity.
+    """
     if use_grpc > 0:
         with grpc.insecure_channel("127.0.0.1:50001") as channel:
             stub = engine_pb2_grpc.EngineStub(channel)
@@ -1390,6 +1755,13 @@ def update_ano_sensitivity(use_grpc: int, hst: str, serv: str, sensitivity: floa
 
 
 def disable_host_svc_checks(use_grpc: int, hst: str):
+    """
+    Disable all the checks on a host (on it and on its services).
+
+    Args:
+        use_grpc (int): If not zero by gRPC, otherwise with legacy commands.
+        hst (str): host name of the concerned host.
+    """
     if use_grpc == 0:
         now = int(time.time())
         cmd = "[{}] DISABLE_HOST_SVC_CHECKS;{}\n".format(
@@ -1400,6 +1772,13 @@ def disable_host_svc_checks(use_grpc: int, hst: str):
 
 
 def enable_host_svc_checks(use_grpc: int, hst: str):
+    """
+    Enable all the checks on a host (on it and on its services).
+
+    Args:
+        use_grpc (int): If not zero by gRPC, otherwise with legacy commands.
+        hst (str): host name of the concerned host.
+    """
     if use_grpc == 0:
         now = int(time.time())
         cmd = "[{}] ENABLE_HOST_SVC_CHECKS;{}\n".format(
@@ -1410,6 +1789,13 @@ def enable_host_svc_checks(use_grpc: int, hst: str):
 
 
 def disable_host_svc_notifications(use_grpc: int, hst: str):
+    """
+    Disable all the notifications on a host (on it and on its services).
+
+    Args:
+        use_grpc (int): If not zero by gRPC, otherwise with legacy commands.
+        hst (str): host name of the concerned host.
+    """
     if use_grpc == 0:
         now = int(time.time())
         cmd = "[{}] DISABLE_HOST_SVC_NOTIFICATIONS;{}\n".format(
@@ -1420,6 +1806,13 @@ def disable_host_svc_notifications(use_grpc: int, hst: str):
 
 
 def enable_host_svc_notifications(use_grpc: int, hst: str):
+    """
+    Enable all the notifications on a host (on it and on its services).
+
+    Args:
+        use_grpc (int): If not zero by gRPC, otherwise with legacy commands.
+        hst (str): host name of the concerned host.
+    """
     if use_grpc == 0:
         now = int(time.time())
         cmd = "[{}] ENABLE_HOST_SVC_NOTIFICATIONS;{}\n".format(
@@ -1430,6 +1823,13 @@ def enable_host_svc_notifications(use_grpc: int, hst: str):
 
 
 def disable_passive_host_checks(use_grpc: int, hst: str):
+    """
+    Diable the passive checks on a host.
+
+    Args:
+        use_grpc (int): If not zero by gRPC, otherwise with legacy commands.
+        hst (str): host name of the concerned host.
+    """
     if use_grpc == 0:
         now = int(time.time())
         cmd = "[{}] DISABLE_PASSIVE_HOST_CHECKS;{}\n".format(
@@ -1440,6 +1840,13 @@ def disable_passive_host_checks(use_grpc: int, hst: str):
 
 
 def enable_passive_host_checks(use_grpc: int, hst: str):
+    """
+    Enable the passive checks on a host.
+
+    Args:
+        use_grpc (int): If not zero by gRPC, otherwise with legacy commands.
+        hst (str): host name of the concerned host.
+    """
     if use_grpc == 0:
         now = int(time.time())
         cmd = "[{}] ENABLE_PASSIVE_HOST_CHECKS;{}\n".format(
@@ -1450,6 +1857,14 @@ def enable_passive_host_checks(use_grpc: int, hst: str):
 
 
 def disable_passive_svc_checks(use_grpc: int, hst: str, svc: str):
+    """
+    Disable the passive checks on a service.
+
+    Args:
+        use_grpc (int): If not zero by gRPC, otherwise with legacy commands.
+        hst (str): host name of the concerned service.
+        svc (str): service description of the concerned service.
+    """
     if use_grpc == 0:
         now = int(time.time())
         cmd = "[{}] DISABLE_PASSIVE_SVC_CHECKS;{};{}\n".format(
@@ -1460,6 +1875,14 @@ 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 checks on a service.
+
+    Args:
+        use_grpc (int): If not zero by gRPC, otherwise with legacy commands.
+        hst (str): host name of the service.
+        svc (str): service description of the service.
+    """
     if use_grpc == 0:
         now = int(time.time())
         cmd = "[{}] ENABLE_PASSIVE_SVC_CHECKS;{};{}\n".format(
@@ -1470,6 +1893,13 @@ def enable_passive_svc_checks(use_grpc: int, hst: str, svc: str):
 
 
 def start_obsessing_over_host(use_grpc: int, hst: str):
+    """
+    Start obsessing over a host.
+
+    Args:
+        use_grpc (int): If not zero by gRPC, otherwise with legacy commands.
+        hst (str): host name of the host.
+    """
     if use_grpc == 0:
         now = int(time.time())
         cmd = "[{}] START_OBSESSING_OVER_HOST;{}\n".format(
@@ -1480,6 +1910,13 @@ def start_obsessing_over_host(use_grpc: int, hst: str):
 
 
 def stop_obsessing_over_host(use_grpc: int, hst: str):
+    """
+    Stop obsessing over a host.
+
+    Args:
+        use_grpc (int): If not zero by gRPC, otherwise with legacy commands.
+        hst (str): host name of the host.
+    """
     if use_grpc == 0:
         now = int(time.time())
         cmd = "[{}] STOP_OBSESSING_OVER_HOST;{}\n".format(
@@ -1490,6 +1927,14 @@ def stop_obsessing_over_host(use_grpc: int, hst: str):
 
 
 def start_obsessing_over_svc(use_grpc: int, hst: str, svc: str):
+    """
+    Start obsessing over a service.
+
+    Args:
+        use_grpc (int): If not zero by gRPC, otherwise with legacy commands.
+        hst (str): host name of the service.
+        svc (str): service description of the service.
+    """
     if use_grpc == 0:
         now = int(time.time())
         cmd = "[{}] START_OBSESSING_OVER_SVC;{};{}\n".format(
@@ -1500,6 +1945,14 @@ def start_obsessing_over_svc(use_grpc: int, hst: str, svc: str):
 
 
 def stop_obsessing_over_svc(use_grpc: int, hst: str, svc: str):
+    """
+    Stop obsessing over a service.
+
+    Args:
+        use_grpc (int): If not zero by gRPC, otherwise with legacy commands.
+        hst (str): host name of the service.
+        svc (str): service description of the service.
+    """
     if use_grpc == 0:
         now = int(time.time())
         cmd = "[{}] STOP_OBSESSING_OVER_SVC;{};{}\n".format(
@@ -1509,16 +1962,18 @@ def stop_obsessing_over_svc(use_grpc: int, hst: str, svc: str):
         f.close()
 
 
-def service_ext_commands(hst: str, svc: str, state: int, output: str):
-    now = int(time.time())
-    cmd = "[{}] PROCESS_SERVICE_CHECK_RESULT;{};{};{};{}\n".format(
-        now, hst, svc, state, output)
-    f = open(VAR_ROOT + "/lib/centreon-engine/config0/rw/centengine.cmd", "w")
-    f.write(cmd)
-    f.close()
+def process_host_check_result(hst: str, state: int, output: str):
+    """
+    Process a host check result.
 
+    Args:
+        hst: Host name of the host.
+        state: State returned by the check.
+        output: Output message of the check.
 
-def process_host_check_result(hst: str, state: int, output: str):
+    Returns:
+        0 on success.
+    """
     now = int(time.time())
     cmd = "[{}] PROCESS_HOST_CHECK_RESULT;{};{};{}\n".format(
         now, hst, state, output)
@@ -1528,6 +1983,17 @@ def process_host_check_result(hst: str, state: int, output: str):
 
 
 def schedule_service_downtime(hst: str, svc: str, duration: int):
+    """
+    Schedule a downtime on a service.
+
+    Args:
+        hst (str): Host name of the service.
+        svc (str): Service description of the service.
+        duration (int): Expected duration in seconds.
+
+    Returns:
+        0 on success.
+    """
     now = int(time.time())
     cmd = "[{2}] SCHEDULE_SVC_DOWNTIME;{0};{1};{2};{3};0;0;{4};admin;Downtime set by admin\n".format(
         hst, svc, now, now+duration, duration)
@@ -1537,6 +2003,17 @@ def schedule_service_downtime(hst: str, svc: str, duration: int):
 
 
 def schedule_service_fixed_downtime(hst: str, svc: str, duration: int):
+    """
+    Schedule a fixed downtime on a service.
+
+    Args:
+        hst (str): Host name of the service.
+        svc (str): Service description of the service.
+        duration (int): Expected duration in seconds.
+
+    Returns:
+        0 on success.
+    """
     now = int(time.time())
     cmd = "[{2}] SCHEDULE_SVC_DOWNTIME;{0};{1};{2};{3};1;0;{4};admin;Downtime set by admin\n".format(
         hst, svc, now, now + duration, duration)
@@ -1546,6 +2023,14 @@ def schedule_service_fixed_downtime(hst: str, svc: str, duration: int):
 
 
 def schedule_host_fixed_downtime(poller: int, hst: str, duration: int):
+    """
+    Schedule a fixed downtime on a host.
+
+    Args:
+        poller (int): Index of the poller to work with.
+        hst (str): host name of the host.
+        duration (int): Expected duration of the downtime in seconds.
+    """
     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)
@@ -1559,6 +2044,14 @@ def schedule_host_fixed_downtime(poller: int, hst: str, duration: int):
 
 
 def schedule_host_downtime(poller: int, hst: str, duration: int):
+    """
+    Schedule a downtime on a host.
+
+    Args:
+        poller (int): Index of the poller to work with.
+        hst (str): host name of the host.
+        duration (int): Expected duration of the downtime in seconds.
+    """
     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)
@@ -1572,6 +2065,13 @@ def schedule_host_downtime(poller: int, hst: str, duration: int):
 
 
 def delete_host_downtimes(poller: int, hst: str):
+    """
+    Delete the downtimes on a host.
+
+    Args:
+        poller (int): Poller ID.
+        hst (str): host name of the host.
+    """
     now = int(time.time())
     cmd = "[{}] DEL_HOST_DOWNTIME_FULL;{};;;;;;;;\n".format(now, hst)
     f = open(
@@ -1581,6 +2081,14 @@ def delete_host_downtimes(poller: int, hst: str):
 
 
 def delete_service_downtime_full(poller: int, hst: str, svc: str):
+    """
+    Delete the downtimes on a service.
+
+    Args:
+        poller (int): Poller ID.
+        hst (str): host name of the service.
+        svc (str):  service description of the service.
+    """
     now = int(time.time())
     cmd = f"[{now}] DEL_SVC_DOWNTIME_FULL;{hst};{svc};;;;;;;\n"
     f = open(
@@ -1590,6 +2098,14 @@ def delete_service_downtime_full(poller: int, hst: str, svc: str):
 
 
 def schedule_forced_svc_check(host: str, svc: str, pipe: str = VAR_ROOT + "/lib/centreon-engine/config0/rw/centengine.cmd"):
+    """
+    Schedule a forced check on a service.
+
+    Args:
+        host (str): host name of the service.
+        svc (str): service description of the service.
+        pipe (str, optional): The command file. Defaults to "{VAR_ROOT}/lib/centreon-engine/config0/rw/centengine.cmd".
+    """
     now = int(time.time())
     f = open(pipe, "w")
     cmd = "[{2}] SCHEDULE_FORCED_SVC_CHECK;{0};{1};{2}\n".format(
@@ -1600,6 +2116,13 @@ def schedule_forced_svc_check(host: str, svc: str, pipe: str = VAR_ROOT + "/lib/
 
 
 def schedule_forced_host_check(host: str, pipe: str = f"{VAR_ROOT}/lib/centreon-engine/config0/rw/centengine.cmd"):
+    """
+    Schedule a forced check on a host.
+
+    Args:
+        host (str): host name of the host.
+        pipe (str, optional): The command file to use. Defaults to "{VAR_ROOT}/lib/centreon-engine/config0/rw/centengine.cmd".
+    """
     now = int(time.time())
     cmd = f"[{now}] SCHEDULE_FORCED_HOST_CHECK;{host};{now}\n"
     with open(pipe, "w") as f:
@@ -1607,25 +2130,64 @@ 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 a severities.cfg file for a given poller.
+
+    Args:
+        poller (int): Index of the poller.
+        nb (int): number of severities.
+        offset (int, optional): Defaults to 1.
+    """
     engine.create_severities(poller, nb, offset)
 
 
 def create_escalations_file(poller: int, name: int, SG: str, contactgroup: str):
+    """
+    Create an escalations.cfg file for a given poller.
+
+    Args:
+        poller (int): Index of the poller.
+        name (int): name of escalations (not used).
+        SG (str): name of a service group.
+        contactgroup (str): name of a contact group.
+    """
     engine.create_escalations_file(poller, name, SG, contactgroup)
 
 
 def create_template_file(poller: int, typ: str, what: str, ids: list):
+    """
+    Create a template file of the form "{typ}Templates.cfg". This should be as
+    generic as possible. In fact, not so generic...
+
+    Args:
+        poller (int): poller ID.
+        typ (str): service, host, ...
+        what (str): A string. It depends on what type of template.
+        ids (list): For each integer in this list, a template is defined.
+    """
     engine.create_template_file(poller, typ, what, ids)
 
 
 def create_tags_file(poller: int, nb: int, offset: int = 1, tag_type: str = ""):
+    """
+    Create a tags file.
+
+    Args:
+        poller (int): poller ID.
+        nb (int): number of tags to create.
+        offset (int, optional): Defaults to 1.
+        tag_type: A string among [servicegroup, hostgroup, servicecategory, hostcategory].
+    """
     engine.create_tags(poller, nb, offset, tag_type)
 
 
 def engine_config_remove_tag(poller: int, tag_id: int):
-    """! remove tags from tags.cfg where tag id = tag_id
-    @param poller  poller index
-    @param tag_id  id of the tag to remove
+    """
+    Remove all the tags from tags.cfg with the given tag ID.
+
+    Args:
+        poller: Poller index.
+        tag_id: ID of the tag to remove.
     """
     filename = f"{CONF_DIR}/config{poller}/tags.cfg"
     with open(filename, "r") as ff:
@@ -1657,6 +2219,13 @@ def engine_config_remove_tag(poller: int, tag_id: int):
 
 
 def config_engine_add_cfg_file(poller: int, cfg: str):
+    """
+    Add a reference to a cfg file in the centengine.cfg file at index _poller_.
+
+    Args:
+        poller (int): Poller ID.
+        cfg (str): Configuration file name to add.
+    """
     ff = open("{}/config{}/centengine.cfg".format(CONF_DIR, poller), "r")
     lines = ff.readlines()
     ff.close()
@@ -1672,6 +2241,14 @@ def config_engine_add_cfg_file(poller: int, cfg: str):
 
 
 def add_severity_to_services(poller: int, severity_id: int, svc_lst):
+    """
+    Add a severity to services.
+
+    Args:
+        poller (int): Index of the poller to work with.
+        severity_id (int): The severity ID.
+        svc_lst (list): A list of service IDs.
+    """
     ff = open("{}/config{}/services.cfg".format(CONF_DIR, poller), "r")
     lines = ff.readlines()
     ff.close()
@@ -1688,6 +2265,13 @@ def add_severity_to_services(poller: int, severity_id: int, svc_lst):
 
 
 def set_services_passive(poller: int, srv_regex):
+    """
+    Set passive a list of services.
+
+    Args:
+        poller (int): Index of the poller to work with.
+        srv_regex (str): A regexp to match service descriptions.
+    """
     ff = open("{}/config{}/services.cfg".format(CONF_DIR, poller), "r")
     lines = ff.readlines()
     ff.close()
@@ -1717,6 +2301,14 @@ def set_services_passive(poller: int, srv_regex):
 
 
 def add_severity_to_hosts(poller: int, severity_id: int, svc_lst):
+    """
+    Add a severity to a list of hosts given by their ID.
+
+    Args:
+        poller (int): Index of the poller to work with.
+        severity_id (int): The severity ID.
+        svc_lst: A list of host IDs.
+    """
     ff = open("{}/config{}/hosts.cfg".format(CONF_DIR, poller), "r")
     lines = ff.readlines()
     ff.close()
@@ -1733,6 +2325,14 @@ def add_severity_to_hosts(poller: int, severity_id: int, svc_lst):
 
 
 def add_template_to_services(poller: int, tmpl: str, svc_lst):
+    """
+    Add a service template to services.
+
+    Args:
+        poller (int): Index of the poller to work with.
+        tmpl (str): The name of the template to add.
+        svc_lst (list): A list of service IDs. We don't take care of host IDs here.
+    """
     ff = open("{}/config{}/services.cfg".format(CONF_DIR, poller), "r")
     lines = ff.readlines()
     ff.close()
@@ -1749,6 +2349,15 @@ def add_template_to_services(poller: int, tmpl: str, svc_lst):
 
 
 def add_tags_to_services(poller: int, type: str, tag_id: str, svc_lst):
+    """
+    Add tags to a list of services given by their ID (just service ID).
+
+    Args:
+        poller (int): Index of the poller to work with.
+        type (str): One string of [group_tags, category_tags].
+        tag_id (str): A string with the tag IDs separated by a comma.
+        svc_lst: A list of service IDs.
+    """
     ff = open("{}/config{}/services.cfg".format(CONF_DIR, poller), "r")
     lines = ff.readlines()
     ff.close()
@@ -1764,6 +2373,12 @@ def add_tags_to_services(poller: int, type: str, tag_id: str, svc_lst):
 
 
 def remove_severities_from_services(poller: int):
+    """
+    Remove severities from services on a poller.
+
+    Args:
+        poller (int): Index of the poller to work with.
+    """
     ff = open("{}/config{}/services.cfg".format(CONF_DIR, poller), "r")
     lines = ff.readlines()
     ff.close()
@@ -1775,6 +2390,12 @@ def remove_severities_from_services(poller: int):
 
 
 def remove_severities_from_hosts(poller: int):
+    """
+    Remove severities from hosts on a poller.
+
+    Args:
+        poller (int): Index of the poller to work with.
+    """
     ff = open("{}/config{}/hosts.cfg".format(CONF_DIR, poller), "r")
     lines = ff.readlines()
     ff.close()
@@ -1784,17 +2405,27 @@ def remove_severities_from_hosts(poller: int):
     ff.writelines(out)
     ff.close()
 
-##
-# @brief Function that search a check, retrieve command index and return check result
-# then it searchs the string "connector::run: id=1090", and then search "connector::_recv_query_execute: id=1090,"
-# and return this line
-#
-# @param debug_file_path path of the debug log file
-# @param str_to_search string after which we will start connector::run search
-#
-
 
 def check_search(debug_file_path: str, str_to_search, timeout=TIMEOUT):
+    """
+    Search a check, retrieve command index and return check result.
+    Then it searchs the string "connector::run: id=\d+",
+    and then search "connector::_recv_query_execute: id=\d+,"
+    and return this line.
+
+    Args:
+        debug_file_path (str): path of the debug log file
+        str_to_search (str): string after which we will start connector::run search
+        timeout (int, 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:
+        A string.
+    """
     limit = time.time() + timeout
     while time.time() < limit:
         cmd_executed = False
@@ -1826,6 +2457,18 @@ def check_search(debug_file_path: str, str_to_search, timeout=TIMEOUT):
 
 
 def add_tags_to_hosts(poller: int, type: str, tag_id: str, hst_lst):
+    """
+    Add tags to a list of hosts.
+
+    Args:
+        poller (int): Index of the poller to work with.
+        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()
@@ -1842,6 +2485,13 @@ def add_tags_to_hosts(poller: int, type: str, tag_id: str, hst_lst):
 
 
 def remove_tags_from_services(poller: int, type: str):
+    """
+    Remove tags from services.
+
+    Args:
+        poller (int): Index of the poller to work with.
+        type (str): The tag type among group_tags or category_tags.
+    """
     ff = open("{}/config{}/services.cfg".format(CONF_DIR, poller), "r")
     lines = ff.readlines()
     ff.close()
@@ -1853,6 +2503,13 @@ def remove_tags_from_services(poller: int, type: str):
 
 
 def remove_tags_from_hosts(poller: int, type: str):
+    """
+    Remove tags from hosts.
+
+    Args:
+        poller (int): Index of the poller to work with.
+        type (str): The tag type among group_tags or category_tags.
+    """
     ff = open("{}/config{}/hosts.cfg".format(CONF_DIR, poller), "r")
     lines = ff.readlines()
     ff.close()
@@ -1864,6 +2521,14 @@ def remove_tags_from_hosts(poller: int, type: str):
 
 
 def add_template_to_services(poller: int, tmpl: str, svc_lst):
+    """
+    Add a service template to services.
+
+    Args:
+        poller (int): Index of the poller to work with.
+        tmpl (str): The name of the template to add.
+        svc_lst (list): A list of service IDs. We don't take care of host IDs here.
+    """
     ff = open("{}/config{}/services.cfg".format(CONF_DIR, poller), "r")
     lines = ff.readlines()
     ff.close()
@@ -1880,6 +2545,14 @@ def add_template_to_services(poller: int, tmpl: str, svc_lst):
 
 
 def add_template_to_hosts(poller: int, tmpl: str, hst_lst):
+    """
+    Add a host template to hosts, each one given by its ID.
+
+    Args:
+        poller (int): Index of the poller to work with.
+        tmpl (str): The name of the template to add.
+        hst_lst (list): A list of host IDs.
+    """
     ff = open("{}/config{}/hosts.cfg".format(CONF_DIR, poller), "r")
     lines = ff.readlines()
     ff.close()
@@ -1896,6 +2569,13 @@ def add_template_to_hosts(poller: int, tmpl: str, hst_lst):
 
 
 def config_engine_remove_cfg_file(poller: int, fic: str):
+    """
+    Remove a config file reference from the centengine.cfg.
+
+    Args:
+        poller (int): The ID of the Engine configuration.
+        fic (str): What file to remove.
+    """
     ff = open("{}/config{}/centengine.cfg".format(CONF_DIR, poller), "r")
     lines = ff.readlines()
     ff.close()
@@ -1919,6 +2599,21 @@ def wrapper(*args):
 
 
 def process_service_check_result_with_metrics(hst: str, svc: str, state: int, output: str, metrics: int, config='config0', metric_name='metric'):
+    """
+    Send a service check result with metrics.
+
+    Args:
+        hst (str): Host name of the service.
+        svc (str): Service description of the service.
+        state (int): State of the check to set.
+        output (str): An output message for the check.
+        metrics (int): The number of metrics that should appear in the result.
+        config (str, optional): Defaults to 'config0' (useful in case of several Engine running).
+        metric_name (str): The base name of metrics. They will appear followed by an integer (for example metric0, metric1, metric2, ...).
+
+    Returns:
+        0 on success.
+    """
     now = int(time.time())
     pd = [output + " | "]
     for m in range(metrics):
@@ -1929,6 +2624,21 @@ def process_service_check_result_with_metrics(hst: str, svc: str, state: int, ou
     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):
+    """
+    Send a service check result.
+
+    Args:
+        hst (str): Host name of the service.
+        svc (str): Service description of the service.
+        state (int): State of the check to set.
+        output (str): An output message for the check.
+        config (str, optional): Defaults to 'config0' (useful in case of several Engine running).
+        use_grpc (int, optional): Defaults to 0 (no).
+        nb_check (int, optional): Defaults to 1. If nb_check > 1, the check result is sent nb_check times.
+
+    Returns:
+        0 on success.
+    """
     if use_grpc > 0:
         port = 50001 + int(config[6:])
         with grpc.insecure_channel(f"127.0.0.1:{port}") as channel:
@@ -1948,6 +2658,17 @@ def process_service_check_result(hst: str, svc: str, state: int, output: str, co
 
 @external_command
 def acknowledge_service_problem(hst, service, typ='NORMAL'):
+    """
+    Send an acknowledgement on a service.
+
+    Args:
+        hst (str): Host name of the service.
+        service (str): Service description.
+        typ (str, optional): Defaults to 'NORMAL'. Possible values are 'NORMAL', 'STICKY' or 'NONE'.
+
+    Returns:
+        0 on success.
+    """
     if typ == 'NORMAL':
         logger.console('acknowledgement is normal')
         sticky = 1
@@ -1963,60 +2684,192 @@ def acknowledge_service_problem(hst, service, typ='NORMAL'):
 
 @external_command
 def remove_service_acknowledgement(hst, service):
+    """
+   Remove a service acknowledgement.
+
+    Args:
+        hst (str): Host name of the service.
+        service (str): Service description of the service.
+
+    Returns:
+        0 on success.
+    """
     return f"REMOVE_SVC_ACKNOWLEDGEMENT;{hst};{service}\n"
 
 
 @external_command
 def send_custom_host_notification(hst, notification_option, author, comment):
+    """
+    Send a custom host notification.
+
+    Args:
+        hst (str): The host name of the concerned host.
+        notification_option (int): The notification option.
+        author (str): The name of the author.
+        comment (str): A comment.
+
+    Returns:
+        0 on success.
+    """
     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 a service comment.
+
+    Args:
+        host_name (str): Host name of the service.
+        svc_description (str): Description of the service.
+        persistent (int): Is the comment persistent?
+        user_name (str): User name of the comment's author.
+        comment (str): Content of the comment.
+
+    Returns:
+        0 on success.
+    """
     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 a host comment.
+
+    Args:
+        host_name (str): Host name of the impacted host.
+        persistent (int): Is the comment persistent?
+        user_name (str): User name of the comment's author.
+        comment (str): Content of the comment.
+
+    Returns:
+        0 on success.
+    """
     return f"ADD_HOST_COMMENT;{host_name};{persistent};{user_name};{comment}\n"
 
 
 @external_command
 def del_host_comment(comment_id):
+    """
+    Delete a host comment.
+
+    Args:
+        comment_id (int): Comment ID.
+
+    Returns:
+        0 on success.
+    """
     return f"DEL_HOST_COMMENT;{comment_id}\n"
 
 
 @external_command
 def change_host_check_command(hst: str, Check_Command: str):
+    """
+    Change a host check command.
+
+    Args:
+        hst (str): Host name of the host.
+        Check_Command (str): New check command to set.
+
+    Returns:
+        0 on success.
+    """
     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 the value of a host custom variable.
+
+    Args:
+        hst (str): The host name of the impacted host.
+        var_name (str): The name of the custom variable.
+        var_value (str): The new value to set.
+
+    Returns:
+        0 on success.
+    """
     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 a service custom variable.
+
+    Args:
+        hst (str): Host name of the service.
+        svc (str): Service description of the service.
+        var_name (str): Name of the custom variable.
+        var_value (str): Value to set.
+
+    Returns:
+        0 on success.
+    """
     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 the global host event handler.
+
+    Args:
+        var_value (str): The new handler to set.
+
+    Returns:
+        0 on success.
+    """
     return "CHANGE_GLOBAL_HOST_EVENT_HANDLER;{}\n".format(var_value)
 
 
 @external_command
 def change_global_svc_event_handler(var_value: str):
+    """
+    Change the global service event handler.
+
+    Args:
+        var_value (str): The new handler to set.
+
+    Returns:
+        0 on SUCCESS.
+    """
     return "CHANGE_GLOBAL_SVC_EVENT_HANDLER;{}\n".format(var_value)
 
 
 @external_command
 def set_svc_notification_number(host_name: string, svc_description: string, value):
+    """
+    Change the notification number of a service.
+
+    Args:
+        host_name (string): Host name of the service.
+        svc_description (string): Service description of the service.
+        value (int): The notification number to set.
+
+    Returns:
+        0 on SUCCESS.
+    """
     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 an anomaly detection threshold file using version 1.
+
+    Args:
+        path (string): The path to the file.
+        host_id (int): The host ID of the dependent service.
+        service_id (int): The service ID of the dependent service.
+        metric_name (string): The metric name we are interested by.
+        values (array): An array of numbers.
+
+    *Example:*
+
+    | `Create Anomaly Threshold File` | /tmp/anomaly_threshold.json | 1 | 1 | metric_1 | ${values} |
+    """
     f = open(path, "w")
     f.write("""[
     {{
@@ -2044,6 +2897,21 @@ def create_anomaly_threshold_file(path: string, host_id: int, service_id: int, m
 
 
 def create_anomaly_threshold_file_V2(path: string, host_id: int, service_id: int, metric_name: string, sensitivity: float, values: array):
+    """
+    Create an anomaly threshold file using the version 2.
+
+    Args:
+        path (string): The path to the file.
+        host_id (int): The host ID of the dependent service.
+        service_id (int): The service ID of the dependent service.
+        metric_name (string): The metric we are interested by.
+        sensitivity (float): The sensitivity.
+        values (array): An array of numbers.
+
+    *Example:*
+
+    | `Create Anomaly Threshold File V2` | /tmp/anomaly_threshold.json | 1 | 1 | metric_1 | 0.5 | ${values} |
+    """
     f = open(path, "w")
     f.write("""[
     {{
@@ -2073,10 +2941,30 @@ def create_anomaly_threshold_file_V2(path: string, host_id: int, service_id: int
 
 
 def grep_retention(poller: int, pattern: str):
+    """
+    Check if the retention.dat file of an Engine contains a string.
+
+    Args:
+        poller (int): ID of the poller to work with.
+        pattern (str): The string to look for.
+
+    Returns:
+        An empty string if not found, or the found string.
+    """
     return Common.grep("{}/log/centreon-engine/config{}/retention.dat".format(VAR_ROOT, poller), pattern)
 
 
 def modify_retention_dat(poller, host, service, key, value):
+    """
+    Modify a parameter of a service in the retention.dat file.
+
+    Args:
+        poller (int): The ID of the poller.
+        host (str): Host name of the concerned service.
+        service (str): Description of the service.
+        key (str): Parameter name to modify.
+        value (str): New value to set.
+    """
     if host != "" and host != "":
         # We want a service
         ff = open(
@@ -2122,6 +3010,15 @@ def modify_retention_dat(poller, host, service, key, value):
 
 
 def modify_retention_dat_host(poller, host, key, value):
+    """
+    Modify a parameter in the retention.dat file for a given host.
+
+    Args:
+        poller (int): ID of the chosen poller.
+        host (str): Host name.
+        key (str): The parameter to change.
+        value (str): The new value to set.
+    """
     if host != "" and host != "":
         # We want a host
         ff = open(
@@ -2159,6 +3056,14 @@ def modify_retention_dat_host(poller, host, key, value):
 
 
 def config_host_command_status(idx: int, cmd_name: str, status: int):
+    """
+    Set the status of a check command.
+
+    Args:
+        idx: ID of the Engine configuration.
+        cmd_name: Name of the command we work on.
+        status: 0, 1, 2 or 3.
+    """
     filename = f"{ETC_ROOT}/centreon-engine/config{idx}/commands.cfg"
     with open(filename, "r") as f:
         lines = f.readlines()