diff --git a/dbt_project.yml b/dbt_project.yml index 1b356b3..7a10f03 100644 --- a/dbt_project.yml +++ b/dbt_project.yml @@ -73,6 +73,7 @@ vars: BALANCES_START: 0 BALANCES_END: 15000000 DROP_UDFS_AND_SPS: False + UPDATE_GHA_TASKS: False STUDIO_TEST_USER_ID: '{{ env_var("STUDIO_TEST_USER_ID", "98d15c30-9fa5-43cd-9c69-3d4c0bb269f5") }}' ENABLE_SNOWFLAKE_SECRETS: '{{ env_var("ENABLE_SNOWFLAKE_SECRETS", "") }}' diff --git a/macros/actions/trigger_dummy_gha.sql b/macros/actions/trigger_dummy_gha.sql new file mode 100644 index 0000000..9792412 --- /dev/null +++ b/macros/actions/trigger_dummy_gha.sql @@ -0,0 +1,25 @@ +{% 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 + );' +{% endset %} + {% do run_query(sql) %} + +{% if target.database.upper() == 'POLYGON' %} + {% set sql %} + alter task silver.trigger_dummy_workflow resume; + {% endset %} + {% do run_query(sql) %} +{% endif %} + +{% endmacro %} \ No newline at end of file diff --git a/macros/create_gha_tasks.sql b/macros/create_gha_tasks.sql new file mode 100644 index 0000000..24b21ed --- /dev/null +++ b/macros/create_gha_tasks.sql @@ -0,0 +1,7 @@ +{% macro create_gha_tasks() %} + {% if var("UPDATE_GHA_TASKS") %} + {% if target.database == 'POLYGON' %} + {{ trigger_dummy_gha() }}; + {% endif %} +{% endif %} +{% endmacro %} \ No newline at end of file