diff --git a/dbt_project.yml b/dbt_project.yml index 37ee11c..2ea102b 100644 --- a/dbt_project.yml +++ b/dbt_project.yml @@ -43,4 +43,5 @@ on-run-start: - '{{create_sps()}}' - '{{create_udfs()}}' - '{{sp_bulk_get_asset_metadata()}}' - - '{{sp_create_bulk_get_balances()}}' \ No newline at end of file + - '{{sp_create_bulk_get_balances()}}' + - '{{sp_create_bulk_get_validator_metadata()}}' \ No newline at end of file diff --git a/macros/create_udfs.sql b/macros/create_udfs.sql index c0bbbc9..e08e502 100644 --- a/macros/create_udfs.sql +++ b/macros/create_udfs.sql @@ -7,4 +7,8 @@ {{ udf_bulk_get_balances() }}; {% endset %} {% do run_query(sql) %} + {% set sql %} + {{ udf_bulk_get_validator_metadata() }}; + {% endset %} + {% do run_query(sql) %} {% endmacro %} diff --git a/macros/run_sp_bulk_get_validator_metadata.sql b/macros/run_sp_bulk_get_validator_metadata.sql new file mode 100644 index 0000000..76e1550 --- /dev/null +++ b/macros/run_sp_bulk_get_validator_metadata.sql @@ -0,0 +1,7 @@ +{% macro run_sp_bulk_get_validator_metadata() %} +{% set sql %} +call silver.sp_bulk_get_validator_metadata(); +{% endset %} + +{% do run_query(sql) %} +{% endmacro %} \ No newline at end of file diff --git a/macros/sp_create_bulk_get_validator_metadata.sql b/macros/sp_create_bulk_get_validator_metadata.sql new file mode 100644 index 0000000..16df5cc --- /dev/null +++ b/macros/sp_create_bulk_get_validator_metadata.sql @@ -0,0 +1,19 @@ +{% macro sp_create_bulk_get_validator_metadata() %} +{% set sql %} +CREATE OR REPLACE PROCEDURE silver.sp_bulk_get_validator_metadata() +RETURNS variant +LANGUAGE SQL +AS +$$ + DECLARE + RESULT VARCHAR; + BEGIN + RESULT:= ( + SELECT + silver.udf_bulk_get_validator_metadata() + ); + RETURN RESULT; + END; +$${% endset %} +{% do run_query(sql) %} +{% endmacro %} \ No newline at end of file diff --git a/macros/udf_bulk_get_validator_metadata.sql b/macros/udf_bulk_get_validator_metadata.sql new file mode 100644 index 0000000..3a004f8 --- /dev/null +++ b/macros/udf_bulk_get_validator_metadata.sql @@ -0,0 +1,8 @@ +{% macro udf_bulk_get_validator_metadata() %} + CREATE + OR REPLACE EXTERNAL FUNCTION silver.udf_bulk_get_validator_metadata() returns text api_integration = aws_osmosis_api_dev AS {% if target.name == "prod" -%} + 'https://k7jc1bnb8i.execute-api.us-east-1.amazonaws.com/prod/get_validator_metadata' + {% else %} + 'https://auacbjh2tj.execute-api.us-east-1.amazonaws.com/dev/get_validator_metadata' + {%- endif %} +{% endmacro %} \ No newline at end of file