Flatten mute_intervals: remove MuteParams wrapper, put timezone on each interval

mute_intervals is now a direct list of intervals instead of a nested
object with timezone + intervals. Each interval carries its own timezone.

https://claude.ai/code/session_01FGiv1N3QcFMWAPT4e1pu93

Author: claude

helm/robusta/values.yaml

@@ -19,12 +19,12 @@ playbookRepos: {}
 #       slack_channel: my-channel
 #       api_key: xoxb-your-key
 #       mute_intervals:
+#       - start_date: "2025-12-24 00:00"
+#         end_date: "2025-12-26 23:59"
 #         timezone: UTC
-#         intervals:
-#         - start_date: "2025-12-24 00:00"
-#           end_date: "2025-12-26 23:59"
-#         - start_date: "2026-01-01 00:00"
-#           end_date: "2026-01-01 23:59"
+#       - start_date: "2026-01-01 00:00"
+#         end_date: "2026-01-01 23:59"
+#         timezone: US/Eastern
 sinksConfig: []
 
 # global parameters

src/robusta/core/sinks/sink_base.py

@@ -8,7 +8,7 @@
 
 from robusta.core.model.k8s_operation_type import K8sOperationType
 from robusta.core.reporting.base import Finding
-from robusta.core.sinks.sink_base_params import ActivityInterval, ActivityParams, MuteParams, SinkBaseParams
+from robusta.core.sinks.sink_base_params import ActivityInterval, ActivityParams, MuteInterval, SinkBaseParams
 from robusta.core.sinks.timing import MuteDateInterval, TimeSlice, TimeSliceAlways
 
 
@@ -152,13 +152,12 @@ def _build_time_slices_from_params(self, params: ActivityParams):
     def _interval_to_time_slice(self, timezone: str, interval: ActivityInterval):
         return TimeSlice(interval.days, [(time.start, time.end) for time in interval.hours], timezone)
 
-    def _build_mute_intervals_from_params(self, params: MuteParams):
-        if params is None:
+    def _build_mute_intervals_from_params(self, params: Optional[List[MuteInterval]]):
+        if not params:
             return []
-        timezone = params.timezone
         return [
-            MuteDateInterval(interval.start_date, interval.end_date, timezone)
-            for interval in params.intervals
+            MuteDateInterval(interval.start_date, interval.end_date, interval.timezone)
+            for interval in params
         ]
 
     def is_global_config_changed(self) -> bool:

src/robusta/core/sinks/sink_base_params.py

@@ -81,27 +81,17 @@ def check_date_time_format(value: str) -> str:
 class MuteInterval(BaseModel):
     start_date: str  # YYYY-MM-DD HH:MM
     end_date: str    # YYYY-MM-DD HH:MM
+    timezone: str = "UTC"
 
     _validator_start = validator("start_date", allow_reuse=True)(check_date_time_format)
     _validator_end = validator("end_date", allow_reuse=True)(check_date_time_format)
 
-
-class MuteParams(BaseModel):
-    timezone: str = "UTC"
-    intervals: List[MuteInterval]
-
     @validator("timezone")
     def check_timezone(cls, timezone: str):
         if timezone not in pytz.all_timezones:
             raise ValueError(f"unknown timezone {timezone}")
         return timezone
 
-    @validator("intervals")
-    def check_intervals(cls, intervals: List[MuteInterval]):
-        if not intervals:
-            raise ValueError("at least one interval has to be specified for mute_intervals")
-        return intervals
-
 
 class RegularNotificationModeParams(BaseModel):
     # This is mandatory because using the regular mode without setting it
@@ -154,7 +144,7 @@ class SinkBaseParams(ABC, BaseModel):
     match: dict = {}
     scope: Optional[ScopeParams]
     activity: Optional[ActivityParams]
-    mute_intervals: Optional[MuteParams]
+    mute_intervals: Optional[List[MuteInterval]]
     grouping: Optional[GroupingParams]
     stop: bool = False  # Stop processing if this sink has been matched
 

tests/test_sink_timing.py

@@ -42,7 +42,7 @@ def test_invalid_time(self, time):
 class TestMuteDateInterval:
     def test_unknown_timezone(self):
         with pytest.raises(ValueError):
-            MuteDateInterval("01-01 00:00", "01-02 00:00", "Mars/Cydonia")
+            MuteDateInterval("2012-01-01 00:00", "2012-01-02 00:00", "Mars/Cydonia")
 
     @pytest.mark.parametrize(
         "start_date,end_date,timezone,expected_muted",