diff --git a/main.py b/main.py
index ed45176..990e675 100644
--- a/main.py
+++ b/main.py
@@ -29,6 +29,8 @@ BUS2_DECODED = "data/parquet/bus2_decoded.parquet"
 
 def run_pipeline():
     os.makedirs("data/logs", exist_ok=True)
+    os.makedirs("data/csv", exist_ok=True)
+    os.makedirs("data/parquet", exist_ok=True)
     if not Path(BUS1_DECODED).exists() or not Path(BUS2_DECODED).exists():
         print("Parsing raw log...")
         parse_log(RAW_LOG, BUS1_CSV, BUS2_CSV)