fix: telemetry INT collector misplacement issue

Closes issue: #348 (closed)

Edited by Georgios P. Katsikas

Merge request reports

Loading
+2 −2
Changes for src/telemetry/backend/service/collectors/gnmi_oc/SubscriptionNew.py: 2 added lines, 2 removed lines.
Original line number Diff line number Diff line
@@ -41,7 +41,7 @@ class Subscription:
        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:
@@ -82,7 +82,7 @@ class Subscription:
        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
+1 −1
Changes for src/telemetry/backend/service/collectors/intcollector/INTCollector.py: 1 added line, 1 removed line.
Original line number Diff line number Diff line
@@ -20,7 +20,7 @@ from apscheduler.schedulers.background import BackgroundScheduler
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
+0 −0

File moved.

+0 −0

File moved.

+1 −2
Changes for src/telemetry/backend/service/collectors/__init__.py: 1 added line, 2 removed lines.
Original line number Diff line number Diff line
@@ -49,7 +49,7 @@ if LOAD_ALL_DEVICE_DRIVERS:
    )

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, [
            {
@@ -58,4 +58,3 @@ if LOAD_ALL_DEVICE_DRIVERS:
            }
        ])
    )
Loading
Loading