flip/polygon-models
1
0
Fork 0
mirror of https://github.com/FlipsideCrypto/polygon-models.git synced 2026-02-06 17:51:57 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

set result (#269)

Browse Source
This commit is contained in:
Austin 2023-10-23 17:24:05 -04:00 committed by GitHub
parent d9125d6c25
commit fa773c5910
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 17 additions and 16 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

33
macros/actions/trigger_dummy_gha.sql
View File

@ -1,25 +1,26 @@
{% macro trigger_dummy_gha() %}
{% set sql %}
EXECUTE IMMEDIATE
'CREATE OR REPLACE task silver.trigger_dummy_workflow
warehouse = DBT_CLOUD
schedule = \'USING CRON 0,20,40 * * * * UTC\'
COMMENT = \'trigger dummy workflow\' AS
select
github_actions.workflow_dispatches(
\'FlipsideCrypto\',
\'polygon-models\',
\'dbt_run_dummy.yml\',
NULL
);'
'CREATE OR REPLACE TASK silver.trigger_dummy_workflow
WAREHOUSE = DBT_CLOUD
SCHEDULE = \'USING CRON 0,20,40 * * * * UTC\'
COMMENT = \'Trigger Dummy Workflow\' AS
DECLARE
rs resultset;
output string;
BEGIN
rs := (SELECT github_actions.workflow_dispatches(\'FlipsideCrypto\', \'polygon-models\', \'dbt_run_dummy.yml\', NULL)::status_code::int AS status_code);
SELECT LISTAGG($1, ';') INTO :output FROM TABLE(result_scan(LAST_QUERY_ID())) LIMIT 1;
CALL SYSTEM$SET_RETURN_VALUE(:output);
END;'
{% endset %}
{% do run_query(sql) %}
{% do run_query(sql) %}
{% if target.database.upper() == 'POLYGON' %}
{% if target.database.upper() == 'POLYGON' %}
{% set sql %}
alter task silver.trigger_dummy_workflow resume;
ALTER TASK silver.trigger_dummy_workflow RESUME;
{% endset %}
{% do run_query(sql) %}
{% endif %}
{% endif %}
{% endmacro %}
{% endmacro %}