Fabio Picchi
08/09/2023, 9:31 PMbucket_by
from context.instance.get_runs
?
I'm wondering if it achieves this behavior:
context.instance.get_runs(
filters=[
RunsFilter(job_name=job_name, tags={"dagster/partition": item["name"]})
for job_name in ["src_lidar_s0", "src_lidar_s1", "src_lidar_s2", "src_lidar_s3", "src_lidar_full"]
],
)
prha
08/09/2023, 10:36 PMget_runs
methodFabio Picchi
08/10/2023, 11:01 AM