Boost efficiency with task automation and organizers.
Expert guidance for Apache NiFi data integration platform including flow design, processors, controller services, process groups, NiFi Registry integration, and cluster configuration. Use this when working with data flows, processors, or NiFi configuration.
See the main Schema Drift Detection skill for comprehensive coverage of schema drift detection and management.
This skill should be used when modifying the database schema, running Prisma migrations, querying the database with Prisma ORM, or working with PostgreSQL in the ClaudeCode Sentiment Monitor project. Specifically trigger this skill for tasks involving schema changes, migrations, Prisma client operations, or database structure questions.
Build and run LLM-powered data processing pipelines with DocETL using Claude models. Use when users say "docetl", want to analyze unstructured data, process documents, extract information, or run ETL tasks on text. Helps with data collection, pipeline creation, execution, and optimization. This version uses Anthropic Claude Haiku for all LLM operations.
Generate execution plans from user queries through intake, research, specification, and validation. Integrated with DecisionLearningIntegration for deterministic, self-learning planning. Use when user provides any query (vague to specific) and needs an executable plan for /execute skill.
Diagnose CI/CD pipeline failures, analyze Jenkins build logs, and troubleshoot deployment issues. Use when builds fail, checking pipeline status, investigating errors, or understanding deployment health.
Store ClickHouse Cloud credentials in Doppler + 1Password for gapless-crypto-clickhouse. Use when setting up new services, rotating credentials, or backing up authentication material. Covers API keys, connection details, and database password storage.
Agent orchestration pattern for multi-step email processing pipeline. Cost tracking, circuit breakers, graceful degradation, specialized agents. Triggers on "agent", "orchestrator", "pipeline", "multi-step processing", "specialized agents".
Use this skill when users need help configuring outputs to route telemetry to SIEMs, data lakes, or other destinations.
Dagster+ Cloud Onboarding Skill This skill automates the setup of Dagster+ Cloud projects, including
Use this agent when reviewing database migrations, data models, or any code that manipulates persistent data. Specializes in validating referential integrity, transaction boundaries, and data validation rules. Triggers on requests like "data integrity review", "database safety check".
Generate Apache Airflow ETL pipelines for government websites and document sources. Explores websites to find downloadable documents, verifies commercial use licenses, and creates complete Airflow DAG assets with daily scheduling. Use when user wants to create ETL pipelines, scrape government documents, or automate document collection workflows.
Firebase Data Connect integration for GraphQL-based data access with PostgreSQL. Use when building GraphQL schemas, queries, mutations, or integrating Firebase Data Connect with Angular applications. Supports type-safe generated SDKs, real-time subscriptions, and server-side data validation.
End-to-end testing scenarios for Supabase - complete workflow tests from project creation to AI features, validation scripts, and comprehensive test suites. Use when testing Supabase integrations, validating AI workflows, running E2E tests, verifying production readiness, or when user mentions Supabase testing, E2E tests, integration testing, pgvector testing, auth testing, or test automation.
Manage Supabase database using Orchestrator AI's storage-based sync system. Use when working with Supabase, database snapshots, migrations, agent exports, N8N workflow exports, backups, or storage scripts. CRITICAL: Prevents direct Supabase operations - all operations MUST use storage/scripts/*.sh
Expert knowledge for implementing distributed sagas in Composable Rust. Use when coordinating multiple aggregates in distributed transactions, implementing compensation logic or rollback flows, working with EventBus trait or Redpanda integration, designing saga state machines, or questions about eventual consistency and distributed transaction patterns.
Catalog and analyze prompts in Flow SDK workflows before conversion. Use to identify prompt formats, variables, and conversion requirements.
BioBlend and Planemo expertise for Galaxy workflow automation. Galaxy API usage, workflow invocation, status checking, error handling, batch processing, and dataset management. Essential for any Galaxy automation project.
Advanced TanStack Query patterns including useInfiniteQuery, QueryClient operations, and optimistic updates. Use for infinite scroll, optimistic UI, or advanced caching scenarios.
Playbook สำหรับ backfill historical data และ reconcile inconsistencies ระหว่าง data sources
BigQuery integration patterns for CA Lobby lobby data with BLN API schema. Use when working with CA Lobby backend, database queries, or data service. Provides CA-specific BigQuery patterns and Flask integration guidance.
Database operations for BAZINGA orchestration system. This skill should be used when agents need to save or retrieve orchestration state, logs, task groups, token usage, or skill outputs. Replaces file-based storage with concurrent-safe SQLite database. Use instead of writing to bazinga/*.json files or docs/orchestration-log.md.
