Merge branch 'feature-NXCALS-7605-fundamental-varible-enhancements' into 'develop'

Resolve NXCALS-7605 "Feature  fundamental varible enhancements"

Closes NXCALS-7605

See merge request !1970

integration-tests/src/python-integration-test/python/nxcals/integrationtests/pytimber/test_pytimber.py

@@ -405,11 +405,13 @@ class TestFundamentals:
         result = ldb.getFundamentals(
             START_TIME, END_TIME, f"ACC_{RANDOM_SUFFIX}:CYCLE%:USER%"
         )
-        res_len = INTERVALS_NUMBER * int((RECORDS_NUMBER + 1) / 2)
+        unique_values_set = set(result)
+        res_len = int((RECORDS_NUMBER + 1) / 2)
         assert res_len == len(result)
         assert f"ACC_{RANDOM_SUFFIX}:CYCLE0:USER0" in [
             fundamental.name for fundamental in result
         ]
+        assert len(result) == len(unique_values_set)
 
     def test_search_fundamental(self, ldb: LoggingDB) -> None:
         result = ldb.searchFundamental(

python/pytimber/pytimber/fundamentals.py

@@ -27,6 +27,9 @@ class Fundamentals:
 
     """
 
+    LSA_CYCLE = "LSA_CYCLE"
+    USER = "USER"
+
     def __init__(
         self,
         fundamental_pattern: str,
@@ -144,10 +147,13 @@ class FundamentalVariable:
         """
         return "CMW"
 
+    def __str__(self) -> str:
+        return self.name
+
 
 def _get_fundamental_variable_from(row: Row, acc: str) -> FundamentalVariable:
-    cycle = row["LSA_CYCLE"]
-    user = row["USER"]
+    cycle = row[Fundamentals.LSA_CYCLE]
+    user = row[Fundamentals.USER]
     return FundamentalVariable(f"{acc}:{cycle}:{user}")
 
 
@@ -173,7 +179,12 @@ class FundamentalsManager:
         self, t1: PyTimberTimeType, t2: PyTimberTimeType, pattern: FundamentalsType
     ) -> List[FundamentalVariable]:
         fund = _convert_to_fundamentals(pattern)
-        ds = self.get_fundamentals_ds(t1, t2, fund)
+        ds = (
+            self.get_fundamentals_ds(t1, t2, fund)
+            .select(Fundamentals.LSA_CYCLE, Fundamentals.USER)
+            .distinct()
+        )
+
         return [_get_fundamental_variable_from(row, fund.acc) for row in ds.collect()]
 
     def get_fundamentals_ds(