diff --git a/macros/streamline/utils.sql b/macros/streamline/utils.sql
index b9411b8..da95b2f 100644
--- a/macros/streamline/utils.sql
+++ b/macros/streamline/utils.sql
@@ -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 %}
\ No newline at end of file