Merge branch 'pr_telemetry_fix' into 'develop'

from common.proto.kpi_manager_pb2            import KpiId

from common.tools.context_queries.Device     import get_device

from common.tools.context_queries.EndPoint   import get_endpoint_names

from typing import List, Tuple, Optional

LOGGER = logging.getLogger(__name__)

def get_subscription_parameters(

        kpi_id : str, kpi_manager_client, context_client, duration, interval

        ) -> list[tuple] | None:

        ) -> Optional[List[Tuple]]:

    """

    Method to get subscription parameters based on KPI ID.

    Returns a list of tuples with subscription parameters.

def get_collector_by_kpi_id(kpi_id: str, kpi_manager_client, context_client, driver_instance_cache

                            ) -> _Collector | None:

                            ) -> Optional[_Collector]:

    """

    Method to get a collector instance based on KPI ID.

    Preconditions:

    )

if LOAD_ALL_DEVICE_DRIVERS:

    from ...collectors.intcollector.INTCollector import INTCollector # pylint: disable=wrong-import-position

    from .intcollector.INTCollector import INTCollector # pylint: disable=wrong-import-position

    COLLECTORS.append(

        (INTCollector, [

            {

            }

        ])

    )

        metric_queue:          Queue,

        mode:                  str        = "stream",

        sample_interval_ns:    int        = 10_000_000_000,

        heartbeat_interval_ns: int | None = None,  # ← NEW

        heartbeat_interval_ns: Optional[int] = None,  # ← NEW

        encoding:              str        = "json_ietf",

        on_update:             Optional[Callable[[dict], None]] = None,

    ) -> None:

        path_list: List[str],

        mode: str,

        sample_interval_ns: int,

        heartbeat_interval_ns: int | None,

        heartbeat_interval_ns: Optional[int],

        encoding: str,

        on_update: Optional[Callable[[dict], None]],

    ) -> None:  # pragma: no cover

from apscheduler.jobstores.memory import MemoryJobStore

from apscheduler.executors.pool import ThreadPoolExecutor

from datetime import datetime

from telemetry.backend.collector_api._Collector import _Collector

from telemetry.backend.service.collector_api._Collector import _Collector

from scapy.all import *

import struct