Playing around with the new functionality to test ...
# dagster-feedback
v
Playing around with the new functionality to test schedules from dagit, if the schedule targets a partitioned job with partitioned assets, it fails with
Tried to access partition_key for a non-partitioned run
. It seems like testing the schedules correctly sets tags and configuration in the results (see screenshot) but those aren’t passed on to the launchpad, which then launches an unpartitioned run. I’d assume it’s also the case for partitioned non-asset jobs, but haven’t tested that. Minimal code example:
Copy code
@asset(partitions_def=StaticPartitionsDefinition(["1", "2"]))
def my_asset(context):
    return context.partition_key


my_job = define_asset_job(
    "my_job",
    "my_asset",
    partitions_def=StaticPartitionsDefinition(["1", "2"]),
)


@schedule("* * * * *", job=my_job)
def my_schedule():
    return my_job.run_request_for_partition(partition_key="1")
👀 1
c
cc @chris
c
Hey Vinnie - thanks for the catch, we need to route the tags through to the launchpad 😅 . Should have a fix up for this next week
daggy success 2
Just following up - still working on it, but fix should be up soon
🌈 1