Skip to content

Commit f1543bf

Browse files
committed
Fix comments
1 parent f646c9d commit f1543bf

3 files changed

Lines changed: 3 additions & 3 deletions

File tree

src/robusta/core/sinks/robusta/dal/supabase_dal.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -762,7 +762,7 @@ def set_cluster_active(self, active: bool) -> None:
762762
except Exception as e:
763763
logging.error(f"Failed to set cluster status active=False error: {e}")
764764

765-
def get_session_token(self) -> Tuple[str, str]:
765+
def get_session_token(self) -> str:
766766
with self.lock:
767767
session_token = self.token_cache.get("session_token")
768768
if not session_token:

src/robusta/integrations/receiver.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -294,7 +294,7 @@ def on_open(self, ws):
294294
"version": RUNNER_VERSION,
295295
"token": self.auth_token,
296296
}
297-
logging.info(f"connecting to server as account_id={account_id}; cluster_name={cluster_name} token={self.auth_token}")
297+
logging.info(f"connecting to server as account_id={account_id}; cluster_name={cluster_name}")
298298
ws.send(json.dumps(open_payload))
299299

300300
def __validate_request(self, action_request: ExternalActionRequest, validate_timestamp: bool) -> ValidationResponse:

src/robusta/model/config.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -37,7 +37,7 @@ def get_sink_by_name(self, sink_name: str) -> Optional[SinkBase]:
3737
def get_all(self) -> Dict[str, SinkBase]:
3838
return self.sinks
3939

40-
def get_robusta_sinks(self) -> list[RobustaSink]:
40+
def get_robusta_sinks(self) -> List[RobustaSink]:
4141
return [sink for sink in self.sinks.values() if isinstance(sink, RobustaSink)]
4242

4343
@classmethod

0 commit comments

Comments
 (0)