Skip to content

Commit ed0178c

Browse files
committed
changess
1 parent 5df775d commit ed0178c

3 files changed

Lines changed: 7 additions & 13 deletions

File tree

src/robusta/core/sinks/slack/preview/slack_sink_preview.py

Lines changed: 1 addition & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -7,8 +7,5 @@ class SlackSinkPreview(SlackSink):
77
params: SlackSinkPreviewParams
88

99
def __init__(self, sink_config: SlackSinkPreviewConfigWrapper, registry):
10-
self.slack_sender = slack_module.SlackSender(
11-
self.api_key, self.account_id, self.cluster_name, self.signing_key, self.slack_channel, is_preview=True
12-
)
13-
super().__init__(sink_config.slack_sink, registry, self.slack_sender)
10+
super().__init__(sink_config.slack_sink_preview, registry, is_preview=True)
1411

src/robusta/core/sinks/slack/preview/slack_sink_preview_params.py

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -37,7 +37,7 @@ def get_custom_template(self) -> Optional[str]:
3737

3838

3939
class SlackSinkPreviewConfigWrapper(SinkConfigBase):
40-
slack_sink: SlackSinkPreviewParams
40+
slack_sink_preview: SlackSinkPreviewParams
4141

4242
def get_params(self) -> SinkBaseParams:
43-
return self.slack_sink
43+
return self.slack_sink_preview

src/robusta/core/sinks/slack/slack_sink.py

Lines changed: 4 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -10,16 +10,13 @@
1010
class SlackSink(SinkBase):
1111
params: SlackSinkParams
1212

13-
def __init__(self, sink_config: SlackSinkConfigWrapper, registry, slack_sender=None):
13+
def __init__(self, sink_config: SlackSinkConfigWrapper, registry, is_preview=False):
1414
super().__init__(sink_config.slack_sink, registry)
1515
self.slack_channel = sink_config.slack_sink.slack_channel
1616
self.api_key = sink_config.slack_sink.api_key
17-
if slack_sender:
18-
self.slack_sender = slack_sender
19-
else:
20-
self.slack_sender = slack_module.SlackSender(
21-
self.api_key, self.account_id, self.cluster_name, self.signing_key, self.slack_channel
22-
)
17+
self.slack_sender = slack_module.SlackSender(
18+
self.api_key, self.account_id, self.cluster_name, self.signing_key, self.slack_channel, is_preview
19+
)
2320
self.registry.subscribe("replace_callback_with_string", self)
2421

2522
def handle_event(self, event_name: str, **kwargs):

0 commit comments

Comments
 (0)