Snowflake-Labs

Shared infrastructure setup for data migration and data validation — prerequisites, compute pool, worker config, and source database/schema capture.

Setup, run, and report on cloud data migration — workflow YAML, migrate_data run, background Monitor (or poll fallback), and end-of-run summary for the user.

Core migration loop for a single stored procedure, function, or BTEQ script. Iterates deploy -> test -> diagnose -> fix until Snowflake output matches source.

Deploy and validate all object types (tables, views, functions, procedures) in dependency order. Triggers: deploy objects, migrate objects, deploy tables, deploy views, migrate functions, migrate procedures.

Capture the data migration + validation strategy (migration type, sync strategy, extraction strategy, target table type; validation type + sync strategy) by driving the data-migration-setup and data-validation-setup wizards to completion.

One-time infrastructure setup for cloud data validation — verify the orchestrator service is ready after the shared infrastructure step.

Set up a migration project — connect to source, initialize, extract objects, convert, and assess. Covers steps 1-5 of the migration lifecycle.

End-to-end database migration to Snowflake. Orchestrates the full migration lifecycle from source connection through initial conversion. Triggers: migrate, migration, migrate to snowflake, end to end migration, e2e migration, full migration.

Deploy a migrated Snowpark/SCOS project to Snowflake as a Code Bundle. Takes the migrated project (its .py entrypoint + supporting modules/config), reminds the user to fix flagged code, writes a code_bundle.yml spec, uploads the whole project to a Snowflake…

Deploy a migrated Snowpark/SCOS project to Snowflake as a Notebook. Takes the .ipynb produced by the migration skill (plus its supporting project files), reminds the user to fix flagged code, uploads the whole project to a Snowflake stage, and creates the…

Migrate Spark scripts and notebooks to Snowflake. Routes to one of two bundled conversion paths and orchestrates the post-conversion pipeline. **Default path: Snowpark Connect (SCOS)**, which preserves the PySpark API surface. The SMA / Snowpark API path is…

Migrates Databricks (DBX) notebooks to Snowflake Workspace notebooks. Preserves original code, only fixes incompatible patterns, flags unsupported features as migration notes. Use when: migrating Databricks notebooks, converting DBX notebooks to Snowflake,…

Generate Abstract Semantic Graph (ASG) from source code (PySpark or Scala) — a structured representation of data flow consumed by downstream DVP skills.

Adapt source and migrated workloads for testing: inject session parameters, add enableHiveSupport(), defer env vars, and record adapted_source in entrypoints.json. Status: design phase.

Generate dvp/04-results/entrypoints.json from an ASG (Warp EntrypointDetector). Triggers: entrypoints, pipelines, entry point inventory.

Scan .py, .ipynb, and .scala files for SMA (Snowpark Migration Accelerator) EWI codes and resolve them. Triggers: fix EWIs, resolve SPRKPY, resolve SPRKSCL, resolve PNDSPY, SMA warnings, migration issues, Scala migration.

Use this skill when the user asks to "prepare an RFP response", "draft an RFP", "respond to an RFP", or needs to compile firm capabilities, track record, investment process, and compliance content for a proposal. Also use when the user mentions "Request for…

Use this skill when the user asks about a borrower's default probability, credit risk drivers, PD scores, risk ratings, or wants to run what-if scenarios on credit metrics like "what if revenue drops 20%" or "recalculate PD with adjusted inputs". Also use…

Use this skill when the user asks which factors are driving returns, wants to compare factor performance across periods, or requests ad-hoc factor exploration like "which factors are working this quarter", "compare momentum vs value", or "factor…

Use this skill when the user wants to optimize portfolio weights, find the efficient frontier, construct a maximum Sharpe or minimum variance portfolio, or rebalance with specific constraints like position caps, sector limits, or ESG minimums. Also use when…

Use this skill when the user asks about anomalies, risk flags, style drift, attribution drift, concentration alerts, or anything unusual in attribution patterns. Also use proactively when generating reports to check for HIGH severity items before presenting…

Use this skill when the user asks to "generate an attribution report", "prepare attribution for the board", "write up quarterly performance", or wants a comprehensive multi-section attribution narrative. Orchestrates multiple tools into a complete report with…

Use this skill to adapt response depth, formatting, and language to the target audience. Activate when the user specifies an audience like "board memo", "client letter", "PM deep-dive", or when generating reports for different stakeholders, even if they don't…

Legacy skill — superseded by multi-level-attribution. This skill redirects to multi-level-attribution which provides full sector/country/industry drill-down, linked period attribution (QTD/YTD/12M), factor cross-reference, and interactive stopping points.

Discover and remove all Snowflake objects created by skills in this repo. Uses the COMMENT tracking tag (sf_sit-is-fleet) to find objects, generates DROP statements, and optionally executes them. Use when: cleaning up after a demo, removing all skill-created…

Primary one-command installer for the synapse-based, vehicle/industry-AGNOSTIC fleet analytics architecture on Snowflake: the FLEET_SA_APP consumer app, the FLEET_ADMIN_APP build console, the three role-scoped synapse MCP tool bundles, the neutral FLEET_APP…

Deploy the Backload Matching Engine demo: a fleet-wide VRP solve over idle-bound trailers + internal volumes + external freight-exchange offers, anchored on the OPENROUTESERVICE_APP.CORE.OPTIMIZATION function. The page picks one or many trailers, calls…

Deploy the routing TOOL_* procedures (AI-geocoded directions, isochrones, POI-in-isochrone, optimization, catchment, delivery/network demos) into FLEET_INTELLIGENCE.ROUTING_TOOLS. These are wrapped by the synapse ROUTING_MCP verbs that the app-level…

Deploy the Dwell & Congestion Analysis demo: create a 12-step Dynamic Table pipeline for state detection, dwell sessionization, H3 congestion heatmaps, SLA alerts, facility utilization, and daily trends. Works with any vehicle type from…

Deploy the Freight Exchange page: a dispatcher-grade marketplace cockpit that mirrors what users do today on Timocom, WTransnet, Teleroute, B2P (NA: DAT, Truckstop, Convoy, Uber Freight). Adds a parallel React route to the ORS Control App that lets…

Deploy the Route Deviation Analysis demo: create projection views from SYNTHETIC_DATASETS.UNIFIED, run 3-step ETL pipeline, and register React dashboard pages. Works with any vehicle type configured via CONFIG table. Use when: setting up route deviation demo,…

Region-generic Emergency Response evacuation-planning demo: a multi-step wizard in the FLEET_SA_APP that, for whatever region/dataset is active, colors the map by procedural hazard-zone risk (flood/wildfire), seeds participants inside the drive-time isochrone…

>-

Use when running a Snowflake Well-Architected Framework (WAF) assessment for a customer account. Three-tier scale: On Track / Needs Improvement / Needs Attention. Results displayed inline; optional HTML export. Triggers: WAF assessment, well-architected,…

Use when a contributor has built a Cortex Code skill locally and wants a pre-PR readiness check before opening a pull request against Snowflake-Labs/cortex-code-skills. Verdict: promote, adapt, or skip — with concrete fixes. Triggers: "review a skill", "is…

Use for ALL requests to install, set up, deploy, or tear down a pre-built Snowflake industry solution. This skill reads a solution's manifest.json for metadata, then executes its setup SQL scripts against the user's Snowflake account. Triggers: install…

Use when designing or operating Snowpipe disaster recovery on Azure ADLS Gen2 — choosing between dual-pipe, RA-GRS, active-active, or Failover Group patterns, and running failover/failback/catchup. Triggers: snowpipe BCDR, snowpipe disaster recovery, snowpipe…

Use when a developer or data engineer wants to assess MLOps maturity, design a promotion strategy (Code/Model/Hybrid), or implement MLOps capabilities (CI/CD, monitoring, retraining, governance) on Snowflake for traditional ML or LLM/GenAI workloads.…

Use when migrating a Snowflake Data Clean Room from V1 (SAMOOHA Provider/Consumer API) to V2 (Collaboration API). Discovers V1 setup via introspection queries, maps constructs to Collaboration API equivalents, converts JinjaSQL templates, and generates…

Use when a user pastes a Snowflake Quickstart URL or asks to learn/walk through a Quickstart. Fetches the source content from GitHub, parses it into stages, checks the learner's environment, and delivers a guided build experience with two modes (learner or…

Create, evaluate, and optimize custom AI functions using Snowflake Cortex AI Complete. Supports text, image, and document inputs. Use when: building LLM-powered functions, evaluating AI function performance, tuning prompts, selecting models, checking async…

Create a new custom AI function. Supports table-based or manual input specification, single or variant outputs. Direct AI_COMPLETE calls or additional pre- and post-processing.

Quick Start demo: Build a toxicity classifier and evaluate it — the fastest way to experience the core create → evaluate workflow.

Interactive demo: Generate pseudo-labels from a strong teacher model, build a cheap student function, and evaluate accuracy. Showcases pseudo-labeling and teacher-student distillation.

Interactive demo: Build a legal contract field extractor and create a weighted composite metric that scores 4 fields independently. Showcases custom evaluation metrics for multi-field AI functions.

Interactive demo: Extract structured fields from SEC 10-K filing PDFs using multimodal AI, create a custom composite metric for per-field scoring, and evaluate extraction accuracy with per-field analysis.

Interactive demo: Build a policy-conditioned ticket router where a seed prompt performs poorly, then watch prompt optimization close the accuracy gap through prompt evolution and Pareto cost/quality analysis. The canonical demo for prompt optimization.

Interactive demo [Experimental]: Build a PII redaction function using Agent Research mode — the agent searches the web for techniques, proposes SQL UDF architectures with pre/post-processing, and you pick the approach. Then optimize the full function body.

Interactive deployment guide for CoCo Control Hub (Cortex Code Credit Manager). Invoke when someone wants to deploy, install, or set up CoCo Control Hub in their Snowflake account. Asks targeted questions about their deployment target (SPCS container vs…

Complete knowledge base for CoCo Control Hub (Cortex Code Credit Manager v2). Invoke whenever someone asks about the app's architecture, pages, data flow, stored procedures, tables, analytics concepts, token economics, LLM-as-Judge evaluation, responsible AI…

Draft on-brand marketing copy – product announcement emails and slide outlines – that follows Peak Outfitters' brand voice and style guidelines. Use whenever the user wants to write marketing content, a launch email, an announcement, or a slide/deck outline,…

Detect anomalies in hot food sales data. Use this skill when the user asks about unusual patterns, spikes, drops, outliers, or unexpected changes in revenue, quantity sold, or transaction counts across stores, categories, states, or items.

Generate a comprehensive sales report by store or by state. Use this skill when the user asks for a sales report, performance summary, store report, state report, executive summary, or full analysis of a specific store or state.

**[REQUIRED]** Use for ALL tasks combining Snowflake Cortex AI functions with Ibis (Python dataframe library): AI_COMPLETE, AI_SENTIMENT, AI_CLASSIFY, AI_EXTRACT, AI_FILTER, AI_SUMMARIZE_AGG, SNOWFLAKE.CORTEX.COMPLETE, SNOWFLAKE.CORTEX.EMBED_TEXT_768/1024,…

Analyze Snowflake AI cost data and generate insights and reports.

Deploy AI Cost Dashboard stored procedures and Streamlit app to Snowflake.

Set up real-time ADS-B aircraft position ingestion from adsb.lol: create tables, network rules, external access integrations, Python ingestion procedures, flight-matching enrichment, scheduled tasks, and optional historical backfill. Subskill of…

Create airport database infrastructure, schemas, cost-attribution tags, airport properties from Overture Maps, gate and runway geometry, and airline reference dimension. Subskill of aviation-installer — must be invoked from the router, not independently. Use…

Create the airport analytics Dynamic Table pipeline: gate analysis (6 DTs), traffic facts (4 DTs), runway crossings, flight tracker, monitoring views, operational KPIs, and the full task DAG. Subskill of aviation-installer — must be invoked from the router…

Set up Aviationstack flight schedule ingestion: create schedule tables, network rule, external access integration with API key secret, Python ingestion procedure, ETL procedure, and scheduled task. Conditional subskill of aviation-installer — only runs when…

Install and configure an airport analytics platform in Snowflake. Routes to sub-skills for base infrastructure setup, ADS-B real-time ingestion, flight schedule ingestion, TSA checkpoint throughput ingestion, and derived analytics pipelines. Use when:…

Set up TSA checkpoint throughput ingestion: create PDF stages, throughput table, network rule, external access integration, Python PDF-fetch and AI_EXTRACT procedures, and weekly scheduled tasks. Optional subskill of aviation-installer. Use when: configuring…

Deploy the Airport Analytics dashboards: Streamlit-in-Snowflake plus the React dashboard via SPCS (Docker build + CREATE SERVICE). Create the Streamlit app, build/push the Docker image, create the SPCS service, and verify the URLs. Use when: deploying…

Discover and remove all Snowflake objects created by the aviation-ops-intelligence skills. Uses the COMMENT tracking tag (sf_sit-is-aviation) to find objects, generates DROP statements in dependency-safe order, and optionally executes them. Use when: cleaning…

Interactive tutorial teaching Snowflake Cortex Agents. Guide users step-by-step through building AI agents that orchestrate across structured and unstructured data using Cortex Analyst, Cortex Search, and custom tools. Use when user wants to learn cortex…

Advanced tutorial teaching Snowflake Cortex Agents with custom tools. Extends the base tutorial by adding stored procedure-based tools (inventory lookup, price calculator, product summary) alongside Cortex Analyst and Cortex Search. Use when user wants to…

Interactive tutorial that teaches Cortex Code CLI from scratch. Guides non-technical users step-by-step through slash commands, skills, special syntax, sessions, and more. Use when the user wants to learn Cortex Code, get started with the CLI, or understand…

Interactive tutorial teaching Snowflake Cortex Search for building semantic search and RAG applications. Guide users through creating search services and querying them using SQL and Python. Use when user wants to learn Cortex Search, semantic search, hybrid…

Deploy the Cortex CLASSIFY_TEXT tutorial notebook to the user's Snowflake account and provide a link to open it in Snowsight. Use when user wants to learn text classification through a Jupyter notebook experience.

Interactive tutorial teaching Snowflake Cortex CLASSIFY_TEXT for categorizing unstructured text. Guide users through classifying customer reviews using Python and SQL. Use when user wants to learn text classification, Cortex LLM functions, or analyze…

Interactive tutorial that teaches Snowflake Dynamic Tables hands-on. The agent guides users step-by-step through building data pipelines with automatic refresh, incremental processing, and CDC patterns. Use when the user wants to learn dynamic tables, build a…

Audit an existing prompt for IDD alignment. Scores it across four dimensions (Goal, Requirements, Constraints, Output), identifies gaps, and offers to hand off to the rewrite skill. Use when: "evaluate this prompt", "audit my prompt", "is this IDD", "score my…

Calculate the Intent Compression Ratio (ICR) for a workflow, script, or CI/CD pipeline. Counts total operations vs intent expressions and classifies the result. Recommends what to compress next to increase agentic readiness. Use when: "measure ICR",…

Guided rewrite of a prompt using the IDD Goal/Requirements/Constraints/Output structure. Collects each section interactively, generates the rewritten prompt, and optionally writes it to a file. Use when: "rewrite this prompt", "improve my prompt", "apply IDD…

Apply Intent-Driven Development (IDD) principles from Kamesh Sampath's IDD series to prompts, workflows, and CI/CD automation. Evaluate existing prompts for IDD alignment, rewrite them using the Goal/Requirements/Constraints/Output structure, or measure the…

Guided 6-step scaffold: set up a new GitHub Actions CoCo agent project from the github-coco-agent template. Provisions Snowflake OIDC resources, sets GitHub secrets, and optionally pushes a sample app to trigger the scan->issue->fix automation loop…

Guided 6-step scaffold: set up a new GitLab CI CoCo agent project from the gitlab-coco-agent template. Provisions Snowflake OIDC resources, sets GitLab CI/CD variables, and optionally pushes a sample app to trigger the scan->issue->fix automation loop…

Guided walkthrough for scaffolding a CoCo agent project on GitHub Actions or GitLab CI, provisioning Snowflake OIDC resources, and running the scan->issue->fix automation loop end-to-end. Use when: "scaffold a project", "scaffold from template", "set up coco…

Internal bootstrap skill shared by all OpenFlow demo skills. Scaffolds project files, resolves Snowflake connection, installs tools, and confirms runtime readiness.

Clean up the Google Drive CDC connector demo. Stops flow, drops schema, resets gate state.

Deploy the Google Drive CDC connector on OpenFlow. Handles runtime selection, EAI setup, PAT creation, and NiFi flow deployment.

Interactive setup for OpenFlow Google Drive demo. Prompts for missing config, creates infrastructure, writes to manifest.

Deploy, clean up, or manage the Google Drive CDC connector (no DWD) on OpenFlow. Use when: openflow demo, gdrive connector, deploy google drive connector, cleanup, reset demo, setup openflow, deploy connector, start connector, configure openflow.

Update network rule IP for OpenFlow Google Drive demo. Use when nipyapi returns 401 after PAT rotation due to network change.

Build and manage Meta Conversions API (CAPI) pipelines in Snowflake. Triggers: set up Meta CAPI, create CAPI pipeline, discover tables, find CAPI candidates, get signal recommendations, run pipeline, send events to Meta, check CAPI status, pipeline health,…

One-command installer for the Snowflake vector-tile demo: dynamic ST_AsMVT tiles served by Martin on SPCS (arm 1), a precomputed PMTiles archive baked from the same data (arm 2), and native H3 aggregation for client-side deck.gl (arm 3). The viewer is…

One-command installer for Snowflake-native geocoding (forward + reverse) built on the Overture Maps Marketplace share, with an optional libpostal SPCS service for international addresses. Deploys the GEOCODING.PUBLIC UDFs and stored procedures, auto-detecting…

Build a first-party identity resolution pipeline on any set of source tables in Snowflake. Discovers source schemas, maps columns to canonical identity fields, generates a fully incremental Dynamic Table pipeline with deterministic and probabilistic matching,…

Build an end-to-end Cloudflare HTTP log analytics pipeline in Snowflake with a Cortex Agent. Ingests Logpush data from R2 into a parsed view, semantic view, and queryable agent. Use when: cloudflare logs, R2 logpush, http log analytics, web traffic agent,…