blast-models/macros/create_udfs.sql
drethereum 251ddd2ac1
AN-4606/decoded-logs (#20)
* decoded logs streamline, silver, core and macros

* realtime job

* vars in workflow

* v2

* wait

* overview docs

* decoder sched

* remove coalesce
2024-03-13 11:21:32 -06:00

18 lines
461 B
SQL

{% macro create_udfs() %}
{% if var("UPDATE_UDFS_AND_SPS") %}
{% set sql %}
CREATE schema if NOT EXISTS silver;
{{ create_udtf_get_base_table(
schema = "streamline"
) }}
{{ create_udf_rest_api() }}
{{ create_aws_blast_api() }}
{{ create_udf_bulk_decode_logs() }}
{% endset %}
{% do run_query(sql) %}
{{- fsc_utils.create_udfs() -}}
{% endif %}
{% endmacro %}