diff --git a/macros/create_udfs.sql b/macros/create_udfs.sql
index ba76b6d..acc6ec9 100644
--- a/macros/create_udfs.sql
+++ b/macros/create_udfs.sql
@@ -11,15 +11,15 @@
             {{ create_udf_s3_copy_objects_overwrite() }}
             {{ create_UDTF_CALL_CONTRACT_FUNCTION() }}
             {{ create_UDTF_CALL_CONTRACT_FUNCTION_BY_HEIGHT() }}
+
+            -- Required for Streamline Pipeline
             {{ create_UDF_GET_CHAINHEAD() }}
+            {{ create_udf_extract_hash_array() }}
+
+            -- Todo - add call to fsc_utils create_udfs and create_streamline_udfs in here ?
         {% endset %}
 
         {% do run_query(sql) %}
 
-        {% set utils_sql %}
-            {{ fsc_utils.create_udfs() }}
-        {% endset %}
-        {% do run_query(utils_sql) %}
-
     {% endif %}
 {% endmacro %}
diff --git a/macros/streamline/create_udf_get_chainhead.sql b/macros/streamline/create_udf_get_chainhead.sql
index ea4c9fc..89fe1bc 100644
--- a/macros/streamline/create_udf_get_chainhead.sql
+++ b/macros/streamline/create_udf_get_chainhead.sql
@@ -1,3 +1,5 @@
+-- todo, what if we receive a bad response?
+-- ask for backend deployment?
 {% macro create_UDF_GET_CHAINHEAD() %}
     {% set sql %}
         CREATE