https://dagster.io/ logo
Powered by
#ask-community
Title
# ask-community
r

Rafael Gomes

01/16/2023, 11:03 PM
How can I achieve the following: I have two jobs: 
A
(static partitioned) and 
B
(daily partitioned). I would like to have a third job 
C
that will trigger 
A
and 
B
(passing the appropriate partitions key).
I did something like this:
Copy code
@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)
It does appear in Dagit I can trigger on launchpad but does nothing.
PS: I did hardcoded the partitions just to illustrate
c

chris

01/17/2023, 9:31 PM
It isn’t doing anything because you haven’t defined any actual ops / computations within the job. a function decorated in 
@job
just services to construct the computation graph
This is better modeled as a sensor/schedule, where you can specifically send off run requests for each of job 
A
and 
B
3 Views
Powered by