diff --git a/pipeline/transform/macros/generate_schema_name.sql b/pipeline/transform/macros/generate_schema_name.sql
new file mode 100644
index 0000000..c60b38e
--- /dev/null
+++ b/pipeline/transform/macros/generate_schema_name.sql
@@ -0,0 +1,7 @@
+{% macro generate_schema_name(custom_schema_name, node) -%}
+    {%- if custom_schema_name is not none -%}
+        {{ custom_schema_name | trim }}
+    {%- else -%}
+        {{ target.schema }}
+    {%- endif -%}
+{%- endmacro %}