example_of_observable_assets.py

example_of_observable_assets.py

@observable_source_asset(
        auto_observe_interval_minutes=24*60
)
def daily_data():
    return DataVersion(str(today()))

@observable_source_asset(
        auto_observe_interval_minutes=10
)
def live_data():
    return DataVersion(str(now()))

@asset(
    deps=[daily_data, live_data], 
    auto_materialize_policy=AutoMaterializePolicy.eager()
)
def downstream():
    return 

@asset(
   deps=[downstream], 
   auto_materialize_policy=AutoMaterializePolicy.eager() 
)
def downstream_downstream():
    return