Programarea Execuțiilor SQL cu CREATE TASK în Snowflake & dbt (Data Stack)

CREATE OR REPLACE TASK task_procesare_orara
  WAREHOUSE = COMPUTE_WH
  SCHEDULE = '60 MINUTE'
  WHEN SYSTEM$STREAM_HAS_DATA('stream_comenzi_noi')
AS
  MERGE INTO analytics.fct_comenzi c
  USING stream_comenzi_noi s ON c.id = s.id
  WHEN MATCHED THEN UPDATE SET c.status = s.status
  WHEN NOT MATCHED THEN INSERT (id, status, valoare) VALUES (s.id, s.status, s.valoare);

-- Pornirea sarcinii (implicit este în starea SUSPENDED):
ALTER TASK task_procesare_orara RESUME;