chore(argus): Update client to 0.15.6

This is an update to the client that brings in new event system.

Author: k0machi

argus/_version.py

@@ -1,21 +1,34 @@
 # file generated by setuptools-scm
 # don't change, don't track in version control
 
-__all__ = ["__version__", "__version_tuple__", "version", "version_tuple"]
+__all__ = [
+    "__version__",
+    "__version_tuple__",
+    "version",
+    "version_tuple",
+    "__commit_id__",
+    "commit_id",
+]
 
 TYPE_CHECKING = False
 if TYPE_CHECKING:
     from typing import Tuple
     from typing import Union
 
     VERSION_TUPLE = Tuple[Union[int, str], ...]
+    COMMIT_ID = Union[str, None]
 else:
     VERSION_TUPLE = object
+    COMMIT_ID = object
 
 version: str
 __version__: str
 __version_tuple__: VERSION_TUPLE
 version_tuple: VERSION_TUPLE
+commit_id: COMMIT_ID
+__commit_id__: COMMIT_ID
 
-__version__ = version = '0.15.5'
-__version_tuple__ = version_tuple = (0, 15, 5)
+__version__ = version = '0.15.6'
+__version_tuple__ = version_tuple = (0, 15, 6)
+
+__commit_id__ = commit_id = 'g46c898c68'

argus/client/sct/client.py

@@ -2,7 +2,7 @@
 from typing import Any
 from uuid import UUID
 from dataclasses import asdict
-from argus.common.sct_types import GeminiResultsRequest, PerformanceResultsRequest
+from argus.common.sct_types import GeminiResultsRequest, PerformanceResultsRequest, RawEventPayload
 from argus.common.enums import ResourceState, TestStatus
 from argus.client.base import ArgusClient
 from argus.client.sct.types import EventsInfo, LogLink, Package
@@ -25,6 +25,7 @@ class Routes(ArgusClient.Routes):
         SUBMIT_PERFORMANCE_RESULTS = "/sct/$id/performance/submit"
         FINALIZE_NEMESIS = "/sct/$id/nemesis/finalize"
         SUBMIT_EVENTS = "/sct/$id/events/submit"
+        SUBMIT_EVENT = "/sct/$id/event/submit"
         SUBMIT_JUNIT_REPORT = "/sct/$id/junit/submit"
 
     def __init__(self, run_id: UUID, auth_token: str, base_url: str, api_version="v1", extra_headers: dict | None = None) -> None:
@@ -81,6 +82,17 @@ def update_scylla_version(self, version: str) -> None:
         response = super().update_product_version(run_type=self.test_type, run_id=self.run_id, product_version=version)
         self.check_response(response)
 
+    def submit_event(self, event_data: RawEventPayload | list[RawEventPayload]):
+        response = self.post(
+            endpoint=self.Routes.SUBMIT_EVENT,
+            location_params={"id": str(self.run_id)},
+            body={
+                **self.generic_body,
+                "data": event_data,
+            }
+        )
+        self.check_response(response)
+
     def submit_sct_logs(self, logs: list[LogLink]) -> None:
         """
             Submits links to logs collected from nodes by SCT

argus/common/sct_types.py

@@ -1,6 +1,21 @@
 from typing import TypedDict
 
 
+class RawEventPayload(TypedDict):
+    run_id: str
+    severity: str
+    ts: float
+    message: str
+    event_type: str
+    received_timestamp: str | None
+    nemesis_name: str | None
+    duration: float | None
+    node: str | None
+    target_node: str | None
+    known_issue: str | None
+    nemesis_status: str | None
+
+
 class RawHDRHistogram(TypedDict):
     start_time: int
     percentile_90: float

argus/version

@@ -1 +1 @@
-0.15.5
+0.15.6