Charlie Bini
05/12/2023, 2:55 PM@run_failure_sensor
def run_execution_interrupted_sensor(context: RunFailureSensorContext):
client = DagsterGraphQLClient(hostname="kipptaf.dagster.cloud")
for event in context.get_step_failure_events():
run_status = client.get_run_status(event.logging_tags["run_id"])
<http://context.log.info|context.log.info>(run_status)
Charlie Bini
05/12/2023, 2:56 PMCharlie Bini
05/12/2023, 2:56 PMalex
05/12/2023, 2:59 PMcontext.instance
has python APIs that may contain what you are looking foralex
05/12/2023, 3:00 PMcontext.dagster_run.status
Charlie Bini
05/12/2023, 3:03 PMCharlie Bini
05/12/2023, 3:04 PM