fraudtwin.iter_partition_query#

fraudtwin.iter_partition_query(run_dir, query, *, shard_id=None, batch_size=10_000)[source][source]#

Execute an out-of-core DuckDB query over partitioned Parquet.

query must reference {source}, which is replaced by a read_parquet relation. Results are yielded in bounded record batches; DuckDB is imported lazily so the core generator has no dependency on it.

Return type:

Iterator[dict[str, Any]]

Parameters:

  • run_dir (str | Path)

  • query (str)

  • shard_id (str | None)

  • batch_size (int)