Here is the code:

def CAMP_restart_sensor(context):
    runs = context.instance.get_runs(
        filters=PipelineRunsFilter(

            # Pipeline to check using the sensor
            pipeline_name="CAMP_pipeline",
            statuses=[PipelineRunStatus.FAILURE],
        ),
    )
    for run in runs:
        # Use the id of the failed run as run_key to avoid duplicate alerts.
        yield RunRequest(...)

When I looked into it, it seems like the PipelineRunsFilter is a GraphQL related function. This also made me curious. How exactly can I integrate GraphQL queries inside python? Is there a specific way or is it like any other GraphQL implementation?

I’ll update the sensor example documentation to include the import statement

We should also consider exporting those from the main dagster package so you can do something like

from dagster import PipelineRunStatus, PipelineRunsFilter

, but need to think about that a bit more