Walid El Bouchikhi
02/02/2023, 11:09 PMFraser Marlow
02/02/2023, 11:22 PMOp
and asset
? https://docs.dagster.io/concepts/partitions-schedules-sensors/asset-sensorsWalid El Bouchikhi
02/02/2023, 11:26 PMdef message_fn(context: RunFailureSensorContext) -> str:
return f"Error: {context.failure_event.message}"
defs = Definitions(
assets=load_assets_from_package_module(assets),
resources={
"dbt": dbt_cli_resource.configured(
{
"project_dir": DBT_PROJECT_PATH,
"profiles_dir": DBT_PROFILES,
},
),
},
sensors=[
make_slack_on_run_failure_sensor(
channel="#dagster-dev",
slack_token="token",
text_fn=message_fn,
dagit_base_url="<http://localhost:3000>",
)
],
)
jamie
02/03/2023, 3:27 PMWalid El Bouchikhi
02/03/2023, 3:49 PMDefinitions
object as you can see in the code
I don't know where to check for registered sensors on dagit interface, also dagster outputs this (even after job fails)
dagster.daemon.SensorDaemon - INFO - Not checking for any runs since no sensors have been started.
jamie
02/03/2023, 4:08 PMdefault_status
parameter of make_slack_on_failure_sensor_
to `DefaultSensorStatus.RUNNING`s