https://github.com/DataTalksClub/data-engineering-zoomcamp/blob/main/cohorts/2025/02-workflow-orchestration/homework.md

image.png


image.png


image.png

SELECT SUM(row_count) AS total_rows -- 24648499
FROM
  (SELECT COUNT(*) AS row_count FROM `ggoggori_de.zoomcamp.yellow_tripdata_2020_01`
    UNION ALL
   SELECT COUNT(*) AS row_count FROM `ggoggori_de.zoomcamp.yellow_tripdata_2020_02`
    UNION ALL
   SELECT COUNT(*) AS row_count FROM `ggoggori_de.zoomcamp.yellow_tripdata_2020_03`
    UNION ALL
   SELECT COUNT(*) AS row_count FROM `ggoggori_de.zoomcamp.yellow_tripdata_2020_04`
    UNION ALL
   SELECT COUNT(*) AS row_count FROM `ggoggori_de.zoomcamp.yellow_tripdata_2020_05`
    UNION ALL
   SELECT COUNT(*) AS row_count FROM `ggoggori_de.zoomcamp.yellow_tripdata_2020_06`
    UNION ALL
   SELECT COUNT(*) AS row_count FROM `ggoggori_de.zoomcamp.yellow_tripdata_2020_07`
    UNION ALL
   SELECT COUNT(*) AS row_count FROM `ggoggori_de.zoomcamp.yellow_tripdata_2020_08`
    UNION ALL
   SELECT COUNT(*) AS row_count FROM `ggoggori_de.zoomcamp.yellow_tripdata_2020_09`
    UNION ALL
   SELECT COUNT(*) AS row_count FROM `ggoggori_de.zoomcamp.yellow_tripdata_2020_10`
    UNION ALL
   SELECT COUNT(*) AS row_count FROM `ggoggori_de.zoomcamp.yellow_tripdata_2020_11`
    UNION ALL
   SELECT COUNT(*) AS row_count FROM `ggoggori_de.zoomcamp.yellow_tripdata_2020_12`
  )

image.png

SELECT SUM(row_count) AS total_rows -- 1734051
FROM (
	 SELECT COUNT(*) AS row_count FROM `ggoggori_de.zoomcamp.green_tripdata_2020_01`
    UNION ALL
   SELECT COUNT(*) AS row_count FROM `ggoggori_de.zoomcamp.green_tripdata_2020_02`
    UNION ALL
   SELECT COUNT(*) AS row_count FROM `ggoggori_de.zoomcamp.green_tripdata_2020_03`
    UNION ALL
   SELECT COUNT(*) AS row_count FROM `ggoggori_de.zoomcamp.green_tripdata_2020_04`
    UNION ALL
   SELECT COUNT(*) AS row_count FROM `ggoggori_de.zoomcamp.green_tripdata_2020_05`
    UNION ALL
   SELECT COUNT(*) AS row_count FROM `ggoggori_de.zoomcamp.green_tripdata_2020_06`
    UNION ALL
   SELECT COUNT(*) AS row_count FROM `ggoggori_de.zoomcamp.green_tripdata_2020_07`
    UNION ALL
   SELECT COUNT(*) AS row_count FROM `ggoggori_de.zoomcamp.green_tripdata_2020_08`
    UNION ALL
   SELECT COUNT(*) AS row_count FROM `ggoggori_de.zoomcamp.green_tripdata_2020_09`
    UNION ALL
   SELECT COUNT(*) AS row_count FROM `ggoggori_de.zoomcamp.green_tripdata_2020_10`
    UNION ALL
   SELECT COUNT(*) AS row_count FROM `ggoggori_de.zoomcamp.green_tripdata_2020_11`
    UNION ALL
   SELECT COUNT(*) AS row_count FROM `ggoggori_de.zoomcamp.green_tripdata_2020_12`
  )

image.png


image.png

2번!

triggers:
  - id: daily
    type: io.kestra.plugin.core.trigger.Schedule
    cron: "@daily"
    timezone: America/New_York

https://kestra.io/docs/workflow-components/triggers/schedule-trigger