[ROB-1848] - Bugfix: add sink param to krr args (#1882)

* add sink param to krr

* fix type

* another bugfix caught

* fix new version

---------

Co-authored-by: arik <alon.arik@gmail.com>

Author: Avi-Robusta

playbooks/robusta_playbooks/krr.py

@@ -36,7 +36,7 @@
 from robusta.integrations.prometheus.utils import generate_prometheus_config
 from robusta.utils.parsing import format_event_templated_string
 
-IMAGE: str = os.getenv("KRR_IMAGE_OVERRIDE", f"{IMAGE_REGISTRY}/krr:v1.24.0")
+IMAGE: str = os.getenv("KRR_IMAGE_OVERRIDE", f"{IMAGE_REGISTRY}/krr:v1.25.1")
 KRR_MEMORY_LIMIT: str = os.getenv("KRR_MEMORY_LIMIT", "2Gi")
 KRR_MEMORY_REQUEST: str = os.getenv("KRR_MEMORY_REQUEST", "2Gi")
 KRR_STRATEGY: str = os.getenv("KRR_STRATEGY", "simple")
@@ -308,7 +308,7 @@ class ProcessScanParams(ActionParams):
     scan_type: str
     result: Any
     scan_id: str
-    start_time: datetime
+    start_time: str
 
 def _emit_failed_scan_event(event, scan_id, start_time, metadata, reason_msg, exception=None, result=None):
     if exception:
@@ -468,7 +468,10 @@ def krr_scan(event: ExecutionBaseEvent, params: KRRParams):
     publish_scan_args = ""
     if KRR_PUSH_SCAN:
         publish_scan_args = f"--publish_scan_url={KRR_PUBLISH_URL} --scan_id={scan_id} --start_time=\"{start_time}\""
-
+        if event.named_sinks:
+            # Append one flag per sink
+            for sink in event.named_sinks:
+                publish_scan_args += f' --named_sinks="{sink}"'
 
     python_command = (
         f"python krr.py {params.strategy} {publish_scan_args} {args_sanitized} {additional_flags} "
@@ -537,7 +540,7 @@ def update_state(state: ScanState) -> None:
             job_name,
             params.timeout,
             secret,
-            custom_annotations=params.custom_annotations,
+            custom_annotations=krr_annotations,
             ttl_seconds_after_finished=43200,
             delete_job_post_execution=False,
             process_name=False,