diff --git a/agent-node/agent_node/core/watcher.py b/agent-node/agent_node/core/watcher.py
index 285ba53..4946f53 100644
--- a/agent-node/agent_node/core/watcher.py
+++ b/agent-node/agent_node/core/watcher.py
@@ -86,6 +86,8 @@
             self.stop_watching(session_id)
         
         print(f"[*] Starting Watcher for Session {session_id} at {root_path}")
+        os.makedirs(root_path, exist_ok=True)
+        
         handler = SyncEventHandler(session_id, root_path, self.callback)
         observer = Observer()
         observer.schedule(handler, root_path, recursive=True)