diff --git a/server_executor_cleaned.py b/server_executor_cleaned.py
index 588b584f..cb428398 100644
--- a/server_executor_cleaned.py
+++ b/server_executor_cleaned.py
@@ -15,7 +15,7 @@ from aiortc.contrib.media import MediaRelay
 from av import AudioFifo
 from whisper_jax import FlaxWhisperPipline
 
-from utils import run_in_executor
+from reflector.utils.server_utils import run_in_executor
 
 logger = logging.getLogger(__name__)
 
diff --git a/file_utilities.py b/utils/file_utilities.py
similarity index 100%
rename from file_utilities.py
rename to utils/file_utilities.py
diff --git a/utils.py b/utils/server_utils.py
similarity index 100%
rename from utils.py
rename to utils/server_utils.py
diff --git a/text_utilities.py b/utils/text_utilities.py
similarity index 100%
rename from text_utilities.py
rename to utils/text_utilities.py
diff --git a/viz_utilities.py b/utils/viz_utilities.py
similarity index 99%
rename from viz_utilities.py
rename to utils/viz_utilities.py
index 7cd41d66..ae38b770 100644
--- a/viz_utilities.py
+++ b/utils/viz_utilities.py
@@ -66,7 +66,7 @@ def create_talk_diff_scatter_viz(timestamp, real_time=False):
     agenda_topics = []
     agenda = []
     # Load the agenda
-    with open("agenda-headers.txt", "r") as f:
+    with open("../agenda-headers.txt", "r") as f:
         for line in f.readlines():
             if line.strip():
                 agenda.append(line.strip())
diff --git a/whisjax.py b/whisjax.py
index d4fd7c5a..73bc9909 100644
--- a/whisjax.py
+++ b/whisjax.py
@@ -22,9 +22,9 @@ from urllib.parse import urlparse
 from whisper_jax import FlaxWhisperPipline
 
 from datetime import datetime
-from file_utilities import upload_files, download_files
-from viz_utilities import create_wordcloud, create_talk_diff_scatter_viz
-from text_utilities import summarize, post_process_transcription
+from reflector.utils.file_utilities import upload_files, download_files
+from reflector.utils.viz_utilities import create_wordcloud, create_talk_diff_scatter_viz
+from reflector.utils.text_utilities import summarize, post_process_transcription
 
 nltk.download('punkt', quiet=True)
 nltk.download('stopwords', quiet=True)
diff --git a/whisjax_realtime.py b/whisjax_realtime.py
index fb26c3b6..f3d52750 100644
--- a/whisjax_realtime.py
+++ b/whisjax_realtime.py
@@ -7,9 +7,9 @@ from pynput import keyboard
 import jax.numpy as jnp
 import wave
 from datetime import datetime
-from file_utilities import upload_files
-from viz_utilities import create_wordcloud, create_talk_diff_scatter_viz
-from text_utilities import summarize, post_process_transcription
+from reflector.utils.file_utilities import upload_files
+from reflector.utils.viz_utilities import create_wordcloud, create_talk_diff_scatter_viz
+from reflector.utils.text_utilities import summarize, post_process_transcription
 from loguru import logger
 import time
 from termcolor import colored