![]() 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.
0 Comments
Leave a Reply. |
AuthorWrite something about yourself. No need to be fancy, just an overview. ArchivesCategories |