if_data_call_wait macro

This commit is contained in:
drethereum 2024-08-01 09:07:14 -06:00
parent ab1369b781
commit 08e36777d8

View File

@ -118,4 +118,49 @@
SELECT
NULL
{% endif %}
{% endmacro %}
{% macro if_data_call_wait(
seconds
) %}
{% if var(
"STREAMLINE_INVOKE_STREAMS"
) %}
{% set query %}
SELECT
1
WHERE
EXISTS(
SELECT
1
FROM
{{ model.schema ~ "." ~ model.alias }}
LIMIT
1
) {% endset %}
{% if execute %}
{% set results = run_query(
query
) %}
{% if results %}
{{ log(
"Waiting...",
info = True
) }}
{% set wait_query %}
SELECT
system$wait(
{{ var(
"WAIT",
{{ seconds }}
) }}
) {% endset %}
{% do run_query(wait_query) %}
{% else %}
SELECT
NULL;
{% endif %}
{% endif %}
{% endif %}
{% endmacro %}