up

Author: brunovcosta

abstra_json_sql/cli.py

@@ -1,5 +1,5 @@
 from pathlib import Path
-from .tables import FileSystemJsonTables
+from .tables import FileSystemJsonLTables
 from .eval import eval_sql
 from argparse import ArgumentParser
 from csv import DictWriter
@@ -9,7 +9,7 @@
 
 
 def query(code: str, workdir: Path, ctx: dict):
-    tables = FileSystemJsonTables(workdir=workdir)
+    tables = FileSystemJsonLTables(workdir=workdir)
     result = eval_sql(code=code, tables=tables, ctx=ctx)
     return result
 

abstra_json_sql/tables.py

@@ -675,6 +675,7 @@ def __init__(self, workdir: Path):
     def _ensure_metadata_table(self):
         """Ensure the metadata table exists"""
         metadata_path = self.workdir / "__schema__.jsonl"
+        self.workdir.mkdir(parents=True, exist_ok=True)
         if not metadata_path.exists():
             metadata_path.write_text("")