The cloud-native orchestrator for the whole development lifecycle, with integrated lineage and observability.

dagster

I have a source observation job/schedule defined as per the docs, but it doesn't seem to be actually doing anything. If I observe assets manually, it works. Going to paste code in thread, if anyone has any insight

```@observable_source_asset(
    required_resource_keys={"snowflake"},
    key_prefix=["load", "builder_excel"],
    group_name="builder_excel",
)
def usage(context):
    result = context.resources.snowflake.execute_query(
        'select max("upload_date") from "BUILDER_EXCEL"."USAGE"',
        fetch_results=True,
    )
    return DataVersion(str(result[0][0]))

@observable_source_asset(
    required_resource_keys={"snowflake"},
    key_prefix=["load", "builder_excel"],
    group_name="builder_excel",
)
def characteristics(context):
    result = context.resources.snowflake.execute_query(
        'select max("upload_date") from "BUILDER_EXCEL"."CHARACTERISTICS"',
        fetch_results=True,
    )
    return DataVersion(str(result[0][0]))

observe_builder_excel = define_asset_job("observe_builder_excel", selection=[usage, characteristics])

observe_builder_excel_schedule = ScheduleDefinition(
    name="observe_builder_excel_schedule",
    cron_schedule="@daily",
    job=observe_builder_excel,
)```