Mark Nemec
05/17/2023, 6:26 PMdagster._core.errors.DagsterInvariantViolationError: Cannot access partition_key for a non-partitioned run
jamie
05/17/2023, 8:44 PMMark Nemec
05/17/2023, 8:52 PM@asset(
partitions_def=MonthlyPartitionsDefinition(
start_date="2022-01-01", timezone="America/New_York", end_offset=1
),
)
def invoices(…)
and schedule
daily_refresh_schedule = ScheduleDefinition(
job=define_asset_job(
name="invoices_job",
selection=[invoices],
),
cron_schedule="0 0 * * *",
)
jamie
05/19/2023, 4:12 PMMark Nemec
05/19/2023, 4:13 PM