diff --git a/macros/create_streamline_udfs.sql b/macros/create_streamline_udfs.sql
index 9b2bad9..f2561bc 100644
--- a/macros/create_streamline_udfs.sql
+++ b/macros/create_streamline_udfs.sql
@@ -1,13 +1,17 @@
 {% macro create_streamline_udfs() %}
     {% if var("UPDATE_UDFS_AND_SPS") %}
+        {% do run_query("CREATE SCHEMA IF NOT EXISTS streamline") %}
+        
         {{ create_udf_bulk_rest_api_v2() }}
     {% endif %}
 {% endmacro %}
 
 {% macro create_evm_streamline_udfs() %}
     {% if var("UPDATE_UDFS_AND_SPS") %}
+        {% do run_query("CREATE SCHEMA IF NOT EXISTS streamline") %}
+        
         {{ create_udf_bulk_rest_api_v2() }}
         {{ create_udf_bulk_decode_logs() }}
         {{ create_udf_bulk_decode_traces() }}
     {% endif %}
-{% endmacro %}
+{% endmacro %}
\ No newline at end of file