Menu
SkillsMP has collected 45 skills from Snowflake-Labs/coco-skills. Open a skill to review its source and details.
Showing 40 of 45 collected skills.
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.
Identify input and output data (files and tables) from source workloads and infer column schemas. Triggers: identify IO, find inputs outputs, map data flow, discover tables files, extract schema.
Fix migrated Snowpark test code until all tests PASS (not just run). Uses git-based iteration to diagnose and resolve PySpark-to-Snowpark API incompatibilities. Triggers: fix migrated tests, make migrated tests pass, snowpark test errors, migration test…
Convert Jupyter notebooks to Python scripts for testing. Triggers: convert notebook, notebook to script, ipynb to py, databricks notebook.
"Initialize DVP workspace and orchestrate validation pipeline. Triggers: start DVP, initialize workspace, setup validation, run DVP, create DVP structure."
Generate synthetic test data (CSV files) for all pipeline inputs based on data_io_schema.json and optionally the ASG for constraints and relationships.
Execute generated pytest suites for source and migrated workloads. Fixes runability issues, ensures source tests pass, ensures migrated tests execute. Triggers: run tests, execute tests, validate migration, test runner.
Generate pytest files for source and migrated workloads based on entrypoints.json.
Fresh PySpark → Snowpark API conversion via the SMA CLI. Bundled sub-skill of `snowpark-api`, loaded only after the parent has determined that the user wants a NEW SMA conversion (intent=migrate, language=Python). Owns SMA CLI detection, the SMA invocation…
Snowpark Python API conversion path via the SMA CLI. Bundled sub-skill of `spark-migration`, invoked by the parent ONLY when the user explicitly asks for an SMA / Snowpark API rewrite (`snowflake.snowpark`, snake_case `with_column` / `group_by` /…
Generate interactive SMA dashboard to track EWIs from conversion. Triggers: sma dashboard, ewi tracker, track EWIs, conversion issues.
Replace embedded file paths in SMA-converted Snowpark code. Use when: migrating Spark code via SMA, fixing file path references, updating storage locations, changing stage prefix. Triggers: replace embedded file paths, embedded file paths, file paths, SMA…
Post-conversion pipeline owner for the Snowpark API path. Bundled sub-skill of `snowpark-api`. Loaded by `migrate-pyspark-to-snowpark-api` after a fresh SMA run, AND directly by `snowpark-api/SKILL.md` when the user wants to operate on an already-migrated SMA…
Standalone assessment of PySpark and Databricks workloads for Snowflake SCOS compatibility. Produces a MigrationReadinessReport.html and AssessmentIR.json without committing to migration. Use when: analyzing Spark workload complexity, generating a migration…
Migrate PySpark and Databricks workloads to Snowflake SCOS (Snowpark Connect for Spark). Use when: converting Spark code to run on Snowflake, analyzing PySpark compatibility, updating imports to Spark Connect equivalents, or migrating from Databricks.…
Migrate Spark Java workloads to Snowflake SCOS (Snowpark Connect for Spark). Use when: converting Java Spark code to run on Snowflake, analyzing Java Spark compatibility, updating imports to Spark Connect equivalents, or migrating from standalone Spark Java.…
Migrate Spark Scala workloads to Snowflake SCOS (Snowpark Connect for Spark). Use when: converting Scala Spark code to run on Snowflake, analyzing Scala Spark compatibility, updating imports to Spark Connect equivalents, or migrating from standalone Spark…
Snowpark Connect (SCOS) skills for migrating and validating PySpark, Spark Scala, and Spark Java workloads on Snowflake. Generates SMA-compatible reports (Issues.csv, InputFilesInventory.csv, ArtifactDependencyInventory.csv) using EWI codes (SPRKCNTPY* for…
Validate a completed PySpark to Snowpark Connect migration across an entire workload. Surveys every entrypoint, weights each by table complexity, groups them into semantic sections, packs them into balanced batches, and runs a pool of dedicated SDK worker…
Validate a completed Spark Java to Snowpark Connect (SCOS) migration by surveying the workload, asking the user to choose up to 10 entrypoints, synthesizing mock data, provisioning isolated test schemas, running the original workload on local Spark + Delta,…
Validate a completed Spark Scala to Snowpark Connect (SCOS) migration across an entire workload. Surveys every entrypoint, weights each by table complexity, optionally scopes to a subset, packs balanced batches, synthesizes mock data, provisions isolated test…
**[REQUIRED]** XO operator workflow system — the single entry point. Triage classifies the request, routes to the right stage reference, and composes multi-stage pathways. Recording (save) and Recall run underneath. Triggers: work item, WI, task, implement,…
Manage the end-to-end lifecycle of the Snowflake and SAP BDC Zero-Copy Integration and connector. Use when: consuming SAP data products in Snowflake, publishing Snowflake databases to SAP BDC with minimal CSN (v1.0, SDK-compatible), analyzing shared SAP data,…
Audits all (or selected) Cortex Agents in a Snowflake account. For each agent the skill reads the live specification, extracts every dependency (semantic views, Cortex Search services, UDFs, warehouses, tables), then checks whether a user-supplied role holds…
Generate SnowPro certification study materials including study plans, domain deep-dives, flashcards, and practice exam questions for any SnowPro exam. Dynamically discovers current certifications and exam versions from Snowflake. Use when asked to study, prep…
Use for ALL requests that mention: ontology, knowledge graph, semantic layer from schema, ontology-on-snowflake, abstract views, ontology metadata tables, KG_NODE, KG_EDGE, build ontology stack, generate ontology from tables, ontology layer generation, map…
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 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 configuring private connectivity from Snowflake OpenFlow (running on SPCS) to AWS-hosted or on-premises data sources via AWS PrivateLink. Covers NLB + VPC Endpoint Service on AWS, then SYSTEM$PROVISION_PRIVATELINK_ENDPOINT, network rules, and…
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…
Use when designing or refactoring Snowflake RBAC: choosing a role hierarchy, creating database/schema access roles, setting up functional roles, deciding between primary and secondary roles, or referencing roles in masking and row access policies. Routes to…
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 when learning Snowflake Semantic View patterns, teaching SV concepts, applying patterns to existing SVs, or building new SVs with best practices. Triggers: semantic view patterns, sv patterns, walk me through, time intelligence, range join, ASOF join,…