Remove unused synchronize_receivers method from formula tests

Signed-off-by: Sahas Subramanian <[email protected]>

Author: shsms

tests/timeseries/_formula_engine/utils.py

@@ -5,15 +5,13 @@
 
 from __future__ import annotations
 
-from datetime import datetime
 from math import isclose
-from typing import overload
 
 from frequenz.channels import Receiver
 
 from frequenz.sdk.microgrid import _data_pipeline
 from frequenz.sdk.microgrid.component import ComponentMetricId
-from frequenz.sdk.timeseries import Sample, Sample3Phase
+from frequenz.sdk.timeseries import Sample
 from frequenz.sdk.timeseries._formula_engine import ResampledFormulaBuilder
 
 
@@ -48,47 +46,3 @@ def equal_float_lists(list1: list[float], list2: list[float]) -> bool:
         and len(list1) == len(list2)
         and all(isclose(v1, v2) for v1, v2 in zip(list1, list2))
     )
-
-
-@overload
-async def synchronize_receivers(
-    receivers: list[Receiver[Sample]],
-) -> None:
-    ...
-
-
-@overload
-async def synchronize_receivers(
-    receivers: list[Receiver[Sample3Phase]],
-) -> None:
-    ...
-
-
-async def synchronize_receivers(
-    receivers: list[Receiver[Sample]] | list[Receiver[Sample3Phase]],
-) -> None:
-    """Check if given receivers are all returning the same timestamp.
-
-    If not, try to synchronize them.
-    """
-    by_ts: dict[datetime, list[Receiver[Sample] | Receiver[Sample3Phase]]] = {}
-    for recv in receivers:
-        while True:
-            sample = await recv.receive()
-            assert sample is not None
-            if isinstance(sample, Sample) and sample.value is None:
-                continue
-            if isinstance(sample, Sample3Phase) and sample.value_p1 is None:
-                continue
-            by_ts.setdefault(sample.timestamp, []).append(recv)
-            break
-    latest_ts = max(by_ts)
-
-    for sample_ts, recvs in by_ts.items():
-        if sample_ts == latest_ts:
-            continue
-        while sample_ts < latest_ts:
-            for recv in recvs:
-                val = await recv.receive()
-                assert val is not None
-                sample_ts = val.timestamp