diff --git a/arroyo-sql-macro/src/lib.rs b/arroyo-sql-macro/src/lib.rs
index 4a346bb8a..b29b94368 100644
--- a/arroyo-sql-macro/src/lib.rs
+++ b/arroyo-sql-macro/src/lib.rs
@@ -197,7 +197,9 @@ fn get_pipeline_module(
 
             #function
 
-            #(#udfs)*
+            mod udfs {
+               #(#udfs)*
+            }
 
             #(#other_defs)*
         }