Data Scientist: Hybrid-Engine Data Processing
Answer data questions through the cheapest engine and surface that can prove the answer, and
decide where the computation should live before touching the data.
Execution surfaces: resident kernel first
A persistent REPL/eval kernel (many harnesses expose one for JavaScript and Python) is the
default surface. Reason: each one-shot process pays roughly a second of spawn-plus-import
overhead and re-scans the input file, while a resident connection amortizes both — after a
one-time load, repeat queries return in milliseconds. Exploration is repeat queries, so this
difference dominates the session.
- JavaScript kernel (Bun): run
scripts/ensure-js-deps.sh once; it prints the absolute
import path for @duckdb/node-api. Dynamic-import it, connect once, query across cells.
- Python kernel: the default surface for Python work. duckdb/numpy/matplotlib are
typically resident; Polars and pyarrow come from
scripts/ensure-py-deps.sh, which
installs them once into a user cache keyed to the kernel's interpreter —
sys.path.insert the printed directory and import. The interpreter itself is never
mutated.
- uv lane (
uv run --with ...): isolation for a heavy or crash-prone one-shot that
should not take the kernel down.
- No kernel (plain-shell harness): the same engines as one-shots —
bun -e for
DuckDB-js, uv run python -c for the Python stack — batching several questions per
process.
Per-surface patterns and pitfalls: read references/execution-surfaces.md before first use.
Engine selection
- DuckDB for SQL-shaped work: direct file queries, joins, aggregation, subqueries,
window functions. It queries CSV/Parquet/JSON in place without loading, spills to disk
past its memory limit, and reads remote files with the same syntax.
- Polars when the pipeline is DataFrame-shaped: expression-chain transforms, reshapes,
streaming datasets past RAM — resident in the Python kernel via
ensure-py-deps.sh.
Read references/polars-lane.md — the current 1.x API differs from widely-memorized
older spellings.
- numpy when numeric work goes beyond SQL/DataFrame aggregation: statistical tests,
linear algebra, FFT, random sampling.
- matplotlib for every chart — read
references/visualization.md first; it carries the
quality bar and a mandatory visual check.
Performance folklore ("X is Nx faster at filtering") varies with data shape, cardinality,
and hardware. When the engine choice materially matters, measure on the actual data instead
of trusting remembered multipliers.
Placement: decide where the computation lives
Probe before you compute — one cell: file size, free RAM, and (when unclear) a row count via
a direct scan. Then place the work:
- Load into memory when the working set stays within roughly a quarter of free RAM AND
the session will run repeated queries:
CREATE TABLE t AS SELECT ... (or a collected
DataFrame) once, then iterate. One scan up front converts every later query from a file
re-scan into milliseconds.
- Query in place / stream when the question is single-pass, or the data exceeds RAM:
DuckDB reads files directly (
FROM 'data.csv'); past RAM, cap DuckDB's memory and let it
spill, or use Polars' streaming engine in the Python kernel. NEVER load a larger-than-RAM
dataset fully into memory — swapping stalls the whole machine, while streaming merely
takes longer.
- Query remotely, in place when the data lives elsewhere: DuckDB reads http(s)/S3
Parquet and CSV with projection and predicate pushdown, so fetch the columns and rows the
question needs, never the whole file. When data sits on another machine you can execute
on, ship the query to the data and return the small result. Rule: result much smaller
than data — move the query; repeated local iteration planned — move a pruned copy of the
data once.
Sizing heuristics and recipes: references/placement.md.
Hard rules
- NEVER use pandas. DuckDB and Polars beat it decisively on every workload this skill
covers, and the environments this skill assumes do not ship it —
.df() on a DuckDB
result raises unless pandas is installed; convert with .pl() via Arrow instead.
- Excel files are not read directly: export to CSV or Parquet first.
Output contract
Answer the question; report row counts and timing for anything heavy; then stop — no bonus
charts, no extra exploration passes beyond what the question needed. Chart when asked, or
when the answer is a shape (trend, distribution, comparison) that prose cannot carry — then
follow references/visualization.md including its visual QA step.
References
| Read |
When |
references/execution-surfaces.md |
before the first query on any surface: kernel patterns, one-shot recipes, escalation rules |
references/polars-lane.md |
DataFrame-shaped pipeline or data past RAM: current API, Arrow handoff, package sets |
references/placement.md |
before heavy or remote work: sizing probe, memory limits, remote reads |
references/visualization.md |
before any chart: type selection, quality bar, CJK fonts, visual QA |
references/uv-setup.md |
uv missing or broken on this machine |
CLI fallback
When no kernel or REPL surface exists, uv run scripts/quick-query.py <file> [SQL]
(--filter <polars-sql-expr>, --describe) answers ad-hoc questions with zero code.
Supports CSV, Parquet, JSON, NDJSON.
1---2name: data-scientist3description: Processes and analyzes data with resident-kernel engines (DuckDB, Polars) and one-shot tools. Use for CSV/parquet/JSON analysis, group-by/join/aggregation, time series, distributions, cleaning, or plotting a dataset.4---5
6# Data Scientist: Hybrid-Engine Data Processing
7
8Answer data questions through the cheapest engine and surface that can prove the answer, and
9decide where the computation should live before touching the data.
10
11## Execution surfaces: resident kernel first
12
13A persistent REPL/eval kernel (many harnesses expose one for JavaScript and Python) is the
14default surface. Reason: each one-shot process pays roughly a second of spawn-plus-import
15overhead and re-scans the input file, while a resident connection amortizes both — after a
16one-time load, repeat queries return in milliseconds. Exploration is repeat queries, so this
17difference dominates the session.
18
191. **JavaScript kernel (Bun)**: run `scripts/ensure-js-deps.sh` once; it prints the absolute
20 import path for `@duckdb/node-api`. Dynamic-import it, connect once, query across cells.
212. **Python kernel**: the default surface for Python work. duckdb/numpy/matplotlib are
22 typically resident; Polars and pyarrow come from `scripts/ensure-py-deps.sh`, which
23 installs them once into a user cache keyed to the kernel's interpreter —
24 `sys.path.insert` the printed directory and import. The interpreter itself is never
25 mutated.
263. **uv lane** (`uv run --with ...`): isolation for a heavy or crash-prone one-shot that
27 should not take the kernel down.
284. **No kernel** (plain-shell harness): the same engines as one-shots — `bun -e` for
29 DuckDB-js, `uv run python -c` for the Python stack — batching several questions per
30 process.
31
32Per-surface patterns and pitfalls: read `references/execution-surfaces.md` before first use.
33
34## Engine selection
35
36- **DuckDB** for SQL-shaped work: direct file queries, joins, aggregation, subqueries,
37 window functions. It queries CSV/Parquet/JSON in place without loading, spills to disk
38 past its memory limit, and reads remote files with the same syntax.
39- **Polars** when the pipeline is DataFrame-shaped: expression-chain transforms, reshapes,
40 streaming datasets past RAM — resident in the Python kernel via `ensure-py-deps.sh`.
41 Read `references/polars-lane.md` — the current 1.x API differs from widely-memorized
42 older spellings.
43- **numpy** when numeric work goes beyond SQL/DataFrame aggregation: statistical tests,
44 linear algebra, FFT, random sampling.
45- **matplotlib** for every chart — read `references/visualization.md` first; it carries the
46 quality bar and a mandatory visual check.
47
48Performance folklore ("X is Nx faster at filtering") varies with data shape, cardinality,
49and hardware. When the engine choice materially matters, measure on the actual data instead
50of trusting remembered multipliers.
51
52## Placement: decide where the computation lives
53
54Probe before you compute — one cell: file size, free RAM, and (when unclear) a row count via
55a direct scan. Then place the work:
56
57- **Load into memory** when the working set stays within roughly a quarter of free RAM AND
58 the session will run repeated queries: `CREATE TABLE t AS SELECT ...` (or a collected
59 DataFrame) once, then iterate. One scan up front converts every later query from a file
60 re-scan into milliseconds.
61- **Query in place / stream** when the question is single-pass, or the data exceeds RAM:
62 DuckDB reads files directly (`FROM 'data.csv'`); past RAM, cap DuckDB's memory and let it
63 spill, or use Polars' streaming engine in the Python kernel. NEVER load a larger-than-RAM
64 dataset fully into memory — swapping stalls the whole machine, while streaming merely
65 takes longer.
66- **Query remotely, in place** when the data lives elsewhere: DuckDB reads http(s)/S3
67 Parquet and CSV with projection and predicate pushdown, so fetch the columns and rows the
68 question needs, never the whole file. When data sits on another machine you can execute
69 on, ship the query to the data and return the small result. Rule: result much smaller
70 than data — move the query; repeated local iteration planned — move a pruned copy of the
71 data once.
72
73Sizing heuristics and recipes: `references/placement.md`.
74
75## Hard rules
76
77- **NEVER use pandas.** DuckDB and Polars beat it decisively on every workload this skill
78 covers, and the environments this skill assumes do not ship it — `.df()` on a DuckDB
79 result raises unless pandas is installed; convert with `.pl()` via Arrow instead.
80- Excel files are not read directly: export to CSV or Parquet first.
81
82## Output contract
83
84Answer the question; report row counts and timing for anything heavy; then stop — no bonus
85charts, no extra exploration passes beyond what the question needed. Chart when asked, or
86when the answer is a shape (trend, distribution, comparison) that prose cannot carry — then
87follow `references/visualization.md` including its visual QA step.
88
89## References
90
91| Read | When |
92| --- | --- |
93| `references/execution-surfaces.md` | before the first query on any surface: kernel patterns, one-shot recipes, escalation rules |
94| `references/polars-lane.md` | DataFrame-shaped pipeline or data past RAM: current API, Arrow handoff, package sets |
95| `references/placement.md` | before heavy or remote work: sizing probe, memory limits, remote reads |
96| `references/visualization.md` | before any chart: type selection, quality bar, CJK fonts, visual QA |
97| `references/uv-setup.md` | uv missing or broken on this machine |
98
99## CLI fallback
100
101When no kernel or REPL surface exists, `uv run scripts/quick-query.py <file> [SQL]`
102(`--filter <polars-sql-expr>`, `--describe`) answers ad-hoc questions with zero code.
103Supports CSV, Parquet, JSON, NDJSON.