Differential D8684 Diff 40807 examples/docs_snippets/docs_snippets/concepts/partitions_schedules_sensors/sensors/sensor_alert.py

Changeset View

Standalone View

View Options

examples/docs_snippets/docs_snippets/concepts/partitions_schedules_sensors/sensors/sensor_alert.py

	from dagster import ModeDefinition, ResourceDefinition, pipeline, sensor, solid			from dagster import (
				ModeDefinition,
				ResourceDefinition,
				pipeline,
				sensor,
				solid,
				)
	from dagster.core.definitions.run_request import RunRequest			from dagster.core.definitions.run_request import RunRequest
	from dagster.core.storage.pipeline_run import PipelineRunStatus, PipelineRunsFilter			from dagster.core.storage.pipeline_run import (
				PipelineRunStatus,
				PipelineRunsFilter,
				)
	from dagster_slack import slack_resource			from dagster_slack import slack_resource


	# start_alert_pipeline_marker			# start_alert_pipeline_marker
	@solid(required_resource_keys={"slack"})			@solid(required_resource_keys={"slack"})
	def slack_message_on_failure_solid(context):			def slack_message_on_failure_solid(context):
	message = f"Solid {context.solid.name} failed"			message = f"Solid {context.solid.name} failed"
	context.resources.slack.chat.post_message(channel="#foo", text=message)			context.resources.slack.chat.post_message(channel="#foo", text=message)


	@pipeline(			@pipeline(
	mode_defs=[			mode_defs=[
	ModeDefinition(name="test", resource_defs={"slack": ResourceDefinition.mock_resource()}),			ModeDefinition(
				name="test",
				resource_defs={"slack": ResourceDefinition.mock_resource()},
				),
	ModeDefinition(name="prod", resource_defs={"slack": slack_resource}),			ModeDefinition(name="prod", resource_defs={"slack": slack_resource}),
	]			]
	)			)
	def failure_alert_pipeline():			def failure_alert_pipeline():
	slack_message_on_failure_solid()			slack_message_on_failure_solid()


	# end_alert_pipeline_marker			# end_alert_pipeline_marker
	Show All 19 Lines