Rafael Gomes01/16/2023, 11:03 PM
(static partitioned) and
(daily partitioned). I would like to have a third job
that will trigger
(passing the appropriate partitions key).
It does appear in Dagit I can trigger on launchpad but does nothing.
@job def C(): static_partitions = ["a", "b", "c"] for sp in static_partitions: A.run_request_for_partition(partition_key=sp) day = "2023-01-16" B.run_request_for_partition(partition_key=day)
chris01/17/2023, 9:31 PM
just services to construct the computation graph