Messages to include deeplinks to the relevant asset page.ĭefault_status ( DefaultSensorStatus) – Whether the sensor starts as running or not. Defaults to “slack_on_freshness_policy”.ĭagit_base_url – (Optional): The base url of your Dagit instance. Name – (Optional): The name of the sensor.

The FreshnessPolicySensorContext and outputs the message blocks you want to send. It can be formatted as plain text,īlocks_fn ( Callable, List ]) – Function which takes in You aren’t, this is the main body text of the message. If youĪre using blocks_fn, this is used as a fallback string to display in notifications. The usage of the text_fn changes depending on whether you’re using blocks_fn. Minutes past its defined freshness policy it currently is. Takes in the FreshnessPolicySensorContext and outputs the message you want to send.ĭefaults to a text message that contains the relevant asset key, and the number of Text_fn ( Optional ( Callable, str ] )) – Function which Notify_when_back_on_time ( bool) – If a success message should be sent when the asset becomes on Sensor will wait before firing an alert (by default, an alert will be fired as soon as Warn_after_minutes_overdue ( float) – How many minutes past the specified FreshnessPolicy this More in the Slack APIĪsset_selection ( AssetSelection) – The selection of assets which this sensor will monitor.Īlerts will only be fired for assets that have a FreshnessPolicy defined.

Tokens are typically either user tokens or bot tokens. Notify_when_back_on_time is set to True, a second slack message will be sent once the assetĬhannel ( str) – The channel to send the message to (e.g. Only a single slack message will be sent (when the asset begins to be out of date). Messages are only fired when the state changes, meaning make_slack_on_freshness_policy_status_change_sensor ( channel, slack_token, asset_selection, warn_after_minutes_overdue=0, notify_when_back_on_time=False, text_fn=, blocks_fn=None, name=None, dagit_base_url=None, default_status=DefaultSensorStatus.STOPPED ) ¶Ĭreate a sensor that will message the given Slack channel whenever an asset in the providedĪssetSelection becomes out of date. getenv ( 'MY_SLACK_TOKEN' ), text_fn = my_message_fn, dagit_base_url = '', ) dagster_slack. Def my_message_fn ( context : HookContext ) -> str : return f 'Op ' ) slack_on_run_failure = make_slack_on_run_failure_sensor ( channel = '#my_channel', slack_token = os.

Slack api documentation