How to schedule a job with a partitioned asset?

[garethbrickman]

I want to schedule an asset job for a partitioned asset so that the partition for the then current day can be materialized.

[garethbrickman]

There's a special purpose method for that: build_schedule_from_partitioned_job. There's a code example included in that documentation that I've copied below:

from dagster import (
    DailyPartitionsDefinition,
    asset,
    build_schedule_from_partitioned_job,
    define_asset_job,
    Definitions,
)

@asset(partitions_def=DailyPartitionsDefinition(start_date="2020-01-01"))
def asset1():
    ...

asset1_job = define_asset_job("asset1_job", selection=[asset1])

# The created schedule will fire daily
asset1_job_schedule = build_schedule_from_partitioned_job(asset1_job)

defs = Definitions(assets=[asset1], schedules=[asset1_job_schedule])

In the beloiw screenshot you can see when testing the schedule evaluation for a given day in the future that the dagster/partition tag will be for that day's date:

There's an additional example linked in our Partitioning assets documentation here.

[v1gnesh]

I may be mistaken, but isn't Dagster trying to move away from needing to define jobs & schedules "manually" like this?