diff --git a/macros/streamline_udfs.sql b/macros/streamline_udfs.sql
index 8585c82..1657394 100644
--- a/macros/streamline_udfs.sql
+++ b/macros/streamline_udfs.sql
@@ -61,10 +61,11 @@
     {%- endif %};
 {% endmacro %}
 
-{% macro create_udf_decode_withrawal_event() %}
+{% macro create_udf_decode_near_event() %}
     CREATE
     OR REPLACE EXTERNAL FUNCTION streamline.udf_decode_near_event(
-        DATA STRING
+        DATA STRING, 
+        EVENT_STRUCT STRING
     ) returns ARRAY api_integration = aws_near_api_stg_v2 AS {% if target.name == "prod" %}
         ''
     {% else %}