from dagster import repository
from openlineage.dagster.sensor import openlineage_sensor
from hello_cereal import hello_cereal_job
from serial_job import serial_job


@repository
def hello_cereal_repository():
    openlineage_sensor_def = openlineage_sensor(
        minimum_interval_seconds=60,
        record_filter_limit=60,
    )
    return [hello_cereal_job, openlineage_sensor_def, serial_job]