analitiq-pipeline-builder

Plugin analitiq-pipeline-builder from marketplace analitiq-claude-code-plugins in analitiq-ai/claude-code-plugins. Commands read from the repo's manifest — 1 month ago.

Skills (5)

• connection-spec

  Connection authoring vocabulary — the parameters/selections/discovered/secret_refs envelope, storage-driven routing, and the credentials-template workflow. Loaded by connection-creator only. Not invoked directly by users.

• endpoint-spec

  Database endpoint authoring vocabulary — database_object identity, columns with native_type and Arrow type, primary_keys, connection-scoped type-map gap authoring, and new-table (pending-creation) derivation. Loaded by private-endpoint-creator only. Not invoked directly by users.

• pipeline-builder

  Build or edit a pipeline JSON document plus its supporting stream, connection, and database-endpoint JSON files, all conforming to the published Analitiq schema contract. Trigger when the user asks to build, scaffold, wire, or generate a data integration pipeline from a named source connector to a n

• pipeline-spec

  Pipeline authoring vocabulary — connection refs, schedule, engine, runtime, streams, status. Loaded by pipeline-creator only. Not invoked directly by users.

• stream-spec

  Stream authoring vocabulary — endpoint refs, source filters/replication/pagination, destinations write modes, mapping assignments, validation rules. Loaded by stream-creator only. Not invoked directly by users.

Subagents (8)

• connection-creator

  Author a connection JSON document conforming to https://schemas.analitiq.ai/connection/latest.json plus a credentials-document template the user fills in. Reads the downloaded connector's `connection_contract` and routes each input/output into the connection's parameters/selections/secret_refs maps

• pipeline-creator

  Author a pipeline JSON document conforming to the published `pipeline` schema. Receives the minted pipeline_id UUID, source + destination connection_id UUIDs, schedule classification, and engine/runtime overrides from the orchestrator. Emits a CreatorOutput JSON object with `entity: pipeline`. The `

• pipeline-drift-classifier

  Compare an authored pipeline (and its streams) against a previous_release_path and emit a DriftVerdict listing structural changes (added/removed streams, changed write mode, mapping target drift, schedule/runtime changes). Informational only; the plugin does not bump versions. Use after Phase 9 vali

• pipeline-provider-researcher

  Collect PipelineFacts from the user — source connector slug, destination connector slug, pipeline slug, replication method, write mode, schedule, runtime overrides. Use when the pipeline-builder skill needs to capture user intent before any authoring. Output is a single PipelineFacts JSON object as

• pipeline-schema-validator

  Validate authored pipeline-plugin documents — one document, one package, or the pipeline's workspace — by submitting them to the analitiq-validator MCP server. Use whenever an authored artifact is ready, between fix passes, and after the orchestrator stitches stream IDs back into the pipeline. Retur

• private-endpoint-creator

  Discover schemas / tables from a live database connection and author one database-endpoint JSON document per selected table, conforming to https://schemas.analitiq.ai/database-endpoint/latest.json, plus a connection-scoped type-map gap file when the connector's type map doesn't cover a discovered na

• registry-browser

  Download a connector from the Analitiq DIP registry (https://github.com/orgs/analitiq-dip-registry/repositories) into the `target_dir` the orchestrator names, as one package: its root document and (for API connectors) its endpoint documents. Verifies the download landed the root document the connect

• stream-creator

  Author a stream JSON document against the published stream contract. Receives the minted stream_id UUID, parent pipeline_id UUID, source + destination endpoint refs (with database_object for connection-scoped endpoints), replication method, write mode, and mapping. Emits a CreatorOutput JSON object

MCP servers (1)

• analitiq-validator

  connects to: https://api.analitiq.ai/v1/mcp/validator/v1

Similar plugins