Cloud Composer DAG Scheduling based on Big Query Table

44 Views Asked by At

I am new to cloud composer and DAG. For one of our projects, we need to run the DAG monthly. But run date is different for each month and each year. So, we are thinking of updating the run date in a big query table and then query that table inside DAG and schedule it based on the dates specified in the table. Is it possible?

I have tried to use a code which I got from google search. But it is not working.

code image
I have tried to add code here.But it is saying formatting is wrong. So adding the image.

0

There are 0 best solutions below