(q: str)
| 357 | |
| 358 | # Get schema using DESCRIBE, with parquet fallback if CSV not available |
| 359 | def _describe(q: str): |
| 360 | conn = self.data_source.connect() |
| 361 | return conn.execute(f"DESCRIBE ({q} LIMIT 0)").fetchall() |
| 362 | try: |
| 363 | result = _describe(query) |
| 364 | except Exception as e: |