dataflow-operator-builder

A generator for DataFlow operators: reusable data-processing components that can generate, filter, refine, or evaluate data. It also creates a command-line wrapper and tests for each operator.

In plain words
What is it for?
Use it to create or scaffold a new DataFlow operator from an interactive interview or a specification file, including registry, unit, smoke, and CLI-related files.
Why use it?
It removes the repetitive setup involved in registering an operator, connecting it to DataFlow storage, adding a CLI, and writing basic tests.

Skill for Claude CodeCodex

Install

Getting it into your agent

One page per mod, every tool's command on it. A separate URL per tool would split the same page into five that compete with each other.

agentmods
npx agentmods add skills/opendcai/dataflow-webui/dataflow-operator-builder
Any agent
npx skills add OpenDCAI/DataFlow-WebUI --skill dataflow-operator-builder
Clone the repo
git clone --depth 1 https://github.com/OpenDCAI/DataFlow-WebUI

Made for: Claude Code, Codex.

Per session 66 Skills are progressive disclosure: only the name and description are preloaded; the body loads when the skill is used.
When invoked 2,078 The whole file, excluding the scripts and references it only reads on demand.
Security scan A 0 findings. Scan, not verified.
Origin original No closer match found in the catalogue.
Token cost

What it costs to keep this loaded

Counted locally with the o200k_base tokenizer, which is exact for GPT models; Claude uses its own tokenizer and its counts differ. Treat this as one consistent yardstick across the catalogue rather than a bill. Prices are per million input tokens.

ModelPer sessionOnce invoked
Fable 5 $0.00066 $0.02078
Opus 5 $0.00033 $0.01039
Sonnet 5 $0.00013 $0.00416
Haiku 4.5 $0.00007 $0.00208

Measured 2d ago against content hash 602980a26897, method: parsed. Prices are Anthropic first-party input rates as of 2026-08-30, from the pricing page.

Security

Grade A, and why

dataflow-operator-builder scanned grade A with 0 findings against 26 rules in 11 categories — prompt injection, anti-refusal, data exfiltration, privilege escalation, supply chain, agent snooping, system-prompt leakage, SSRF and excessive agency — measured 2d ago.

The scan reads SKILL.md. This mod also ships 1 executable file (scripts/build_operator_artifacts.py), listed below but not scanned — reading those needs a real analyzer, not pattern matching.

A static scan of the body, not an audit. Every finding is printed with the line that produced it so you can judge whether it matters here. A mod is markdown that instructs an agent; that is exactly why what it instructs is worth reading.

Nothing flagged

None of the 26 patterns this scan looks for appear in this file: no shell pipes, no recursive deletes, no credential paths, no hidden text, no instruction-override or anti-refusal phrasing, no agent-config snooping. That is not a guarantee, it is the absence of the things that are checkable.

skills/canonical/dataflow-operator-builder/SKILL.md · 267 lines

How it starts

The opening of the file, as written. The whole thing — 267 lines — stays where its author put it; the contents beside it link to each section on GitHub.

DataFlow Operator Builder

Build production-ready DataFlow operator artifacts with either interactive interview mode or direct spec mode.

ZH: 通过“交互采访模式”或“直接 spec 模式”快速生成生产可用的 DataFlow Operator。

Usage

/dataflow-operator-builder
/dataflow-operator-builder --spec path/to/spec.json --output-root path/to/repo
/dataflow-operator-builder --dry-run --spec path/to/spec.json --output-root path/to/repo

Script Directory

Agent execution instructions:

  1. Resolve this SKILL.md directory as SKILL_DIR.
  2. Use ${SKILL_DIR}/scripts/build_operator_artifacts.py.

ZH:

  1. 将当前 SKILL.md 所在目录作为 SKILL_DIR
  2. 使用 ${SKILL_DIR}/scripts/build_operator_artifacts.py
Script Purpose
scripts/build_operator_artifacts.py Generate operator + CLI + tests from spec
scripts/example_spec.json Example input spec with defaults

Scope

This skill targets:

  • DataFlow-style operator implementation (DataFlowStorage + dataframe flow)
  • @OPERATOR_REGISTRY.register() registration
  • Separate CLI wrapper under cli/
  • Minimal but production-grade tests (unit/registry/smoke)

ZH:

  • 面向 DataFlow 风格的 operator 实现(DataFlowStorage + dataframe 流程)
  • 自动包含 @OPERATOR_REGISTRY.register() 注册
  • CLI 与 operator 逻辑分离
  • 生成最小但可用的测试骨架(unit/registry/smoke

Default families:

  • generate
  • filter
  • refine
  • eval

Two Working Modes

Mode A: Interactive Interview Mode

Use AskUserQuestion in batch mode with exactly two rounds:

Use structured questioning in batch mode with exactly two rounds:

  • Round 1: structure fields
  • Round 2: implementation fields

Important:

  • In each question block, include recommended option + short reason.
  • Ask follow-up questions only when high-impact fields are missing or contradictory.
  • Do not ask one-by-one when the same round can be asked in one batch.
  • Present all questions of one round in a single message to the user, grouped by round.

Read the full file on GitHub · 267 lines

Changes

What this file has done since we first saw it

Hashed on every crawl. A supply-chain change to an agent config is a question of when, not whether, so the history is kept rather than the latest state alone.

  1. 2d ago First seen · 267 lines · 66 tokens per session scan A 602980a26897

Subscribe to this mod's changes

dataflow-operator-builder is a skill published in the GitHub repository OpenDCAI/DataFlow-WebUI (224 stars, last pushed 6d ago), licensed Apache-2.0. It adds 66 tokens to every session and 2,078 once invoked, about $0.0003 per session on Opus 5. A static security scan graded it A with 0 findings. No closer match exists in the catalogue, so it is treated as the original; first seen 2026-08-30.

Related

Other skills, from other repositories

systematic-debugging

Use when encountering any bug, test failure, or unexpected behavior, before proposing fixes.

obra/superpowers · 21 tokens

next-cache-components-adoption

Turn on Cache Components in a Next.js app and resolve the blocking routes it surfaces. Use when the user wants to enable, adopt, or migrate to Cache Components, flip the cacheComponents flag, work through a flood of blocking-prerender / instant validation errors, run the cache-components-instant-false codemod, or…

vercel/next.js · 95 tokens

babysit-pr

Babysit a GitHub pull request after creation by continuously polling review comments, CI checks/workflow runs, and mergeability state until the PR is merged/closed or user help is required. Diagnose failures, retry likely flaky failures up to 3 times, auto-fix/push branch-related issues when appropriate, and keep…

openai/codex · 114 tokens

imagegen

Generate or edit raster images when the task benefits from AI-created bitmap visuals such as photos, illustrations, textures, sprites, mockups, or transparent-background cutouts. Use when Codex should create a brand-new image, transform an existing image, or derive visual variants from references, and the output…

openai/codex · 113 tokens

cpu-profile-analysis

Analyze V8/Chrome CPU profiles (.cpuprofile) and DevTools trace files (Trace-.json). Use when: profiling performance, investigating slow functions, comparing code paths, finding bottlenecks, analyzing timeToRequest, understanding call trees from sampling profiler data, analyzing layout/paint/rendering, investigating…

microsoft/vscode · 71 tokens

next-cache-components-optimizer

Drive a Next.js route to instant navigation by setting up an agentic loop, under Cache Components / PPR, on initial load (hard navigation) and client-side navigation (soft navigation). Encode the goal as a failing @next/playwright instant() e2e and work it to green, one verified route at a time; the shipped test then…

vercel/next.js · 170 tokens