From 3f7c541e2fc07edd58427e43eebaf28f7259d97a Mon Sep 17 00:00:00 2001 From: Arik Alon Date: Mon, 27 May 2024 16:53:19 +0300 Subject: [PATCH] call execute on supabase rpc --- src/robusta/core/sinks/robusta/dal/supabase_dal.py | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/src/robusta/core/sinks/robusta/dal/supabase_dal.py b/src/robusta/core/sinks/robusta/dal/supabase_dal.py index a35b29da9..71e49e32e 100644 --- a/src/robusta/core/sinks/robusta/dal/supabase_dal.py +++ b/src/robusta/core/sinks/robusta/dal/supabase_dal.py @@ -107,7 +107,7 @@ def insert_scan_meta(self, scan_id: str, start_time: datetime, scan_type: ScanTy "_scan_start": str(start_time), "_type": scan_type, }, - ) + ).execute() except requests.exceptions.HTTPError as e: logging.exception(f"Failed to insert scan meta {scan_id}, error: {e}, response: {e.response.text}") raise @@ -543,7 +543,7 @@ def publish_cluster_nodes(self, node_count: int, pod_count: int): "_pod_count": pod_count, } try: - self.client.rpc(UPDATE_CLUSTER_NODE_COUNT, data) + self.client.rpc(UPDATE_CLUSTER_NODE_COUNT, data).execute() except Exception as e: logging.error(f"Failed to publish node count {data} error: {e}")