Skip to main content

pull_schema

Function pull_schema 

Source
pub fn pull_schema(base_path: &Path) -> Result<String, Error>
Expand description

Scans the given base path for .parquet files and generates Lutra function definitions that use std::fs::read_parquet() to read them.

Does not traverse links.

Handles:

  • Recursive directory traversal
  • Parquet metadata reading
  • Type inference from schemas
  • Intelligent nullability detection