dask

Scale pandas and NumPy workflows beyond memory using parallel and distributed computing.

Updated Oct 7, 2022
One-click install
npx skills add https://github.com/tamagusko/linux-cfg --skill dask-tamagusko
Or copy as Structured Prompt for Agent
Please help me install this Agent Skill.
Skill: dask
Source: https://github.com/tamagusko/linux-cfg/tree/main/dotfiles/claude/skills/dask
Command: npx skills add https://github.com/tamagusko/linux-cfg --skill dask-tamagusko

SYSTEM DOCUMENTATION & REQUIREMENTS

💡 This Skill requires dask, distributed, and includes references (resource) components.

What problem does it solve? Pandas and NumPy fail when datasets exceed available RAM or when computations take too long on a single core. This Skill provides guidance for scaling existing Python data workflows to larger-than-memory datasets and multi-machine clusters using Dask. ## Core Features & Use Cases - Parallel DataFrames and Arrays: Scale pandas and NumPy operations across partitions and chunks with familiar APIs and lazy evaluation. - Unstructured Data Processing: Use Dask Bags to clean and transform JSON, logs, and text before converting to structured DataFrames. - Custom Distributed Workflows: Build dynamic task pipelines with Futures, actors, and distributed coordination primitives. - Use Case: You have 200 GB of CSV logs that crash pandas. Use this Skill to read them with dd.read_csv, filter and aggregate with groupby, and write the summary to Parquet without loading everything into memory. ## Quick Start Use the dask skill to read all CSV files in my data folder, filter invalid rows, and compute per-category averages without running out of memory.

Frequently Asked Questions about dask

High-intent search queries and answers about installing and using this skill.

FAQPage Schema
How do I process a CSV file larger than RAM in Python?

Use dask.dataframe.read_csv to load the file lazily in partitions instead of pandas. Operations like filtering and groupby build a task graph and only execute when you call compute(), so the full dataset never sits in memory.

What is the difference between Dask DataFrames, Arrays, and Bags?

DataFrames parallelize pandas for tabular data, Arrays parallelize NumPy for numeric data using blocked algorithms, and Bags handle unstructured data like JSON or logs with functional operations. Convert Bags to DataFrames once data is structured.

Dask vs polars vs vaex: which should I use?

Use Dask when scaling existing pandas or NumPy code beyond memory or across clusters. Use vaex for out-of-core analytics on a single machine and polars for fast in-memory processing, as noted in the skill's selection guidance.

Which Dask scheduler should I use for my workload?

Use threads for NumPy and pandas operations that release the GIL, processes for pure Python code, synchronous for debugging with pdb, and the distributed scheduler when you need the dashboard or multi-machine clusters.

Why is my Dask computation slow to start?

A slow start usually means the task graph is too large, often millions of tiny tasks. Increase chunk sizes toward roughly 100 MB per chunk or fuse operations with map_partitions or map_blocks to reduce task count.

When should I not use Dask?

Avoid Dask when data fits comfortably in memory and computations finish quickly with pandas or NumPy. First try better algorithms, efficient formats like Parquet, compiled code via Numba, or data sampling before adding distributed complexity.