Stephen Bailey
12/10/2022, 2:11 AMJobSelector
threw a warning or something if a job didn't exist. We had an instance today where we refactored a repo, and didn't find out for several days that this sensor wasnt' being tripped!
(Although maybe freshness policies will fix this 🙂 )
@run_status_sensor(
run_status=DagsterRunStatus.SUCCESS,
request_job=my_job,
monitored_jobs=[
JobSelector(
location_name="my_location",
repository_name="my_repo",
job_name="my_job",
)
]
)
def my_run_sensor(context: RunStatusSensorContext):
yield RunRequest(run_key=str(context.dagster_run.run_id))