Not in the top 1,000 by GitHub stars

ivanshamaev/de-agent-skills

Профессиональные Data Engineering Agent Skills для разработки AI Agentic Data Platform

History

Review weekly changes to SKILL.md before updating. Dates mark the weeks in which we observed each version; checks apply to the recorded commits.

View weekly changes

group_skills/infra_dataops_group_skills/aiops_autonomous_incident_response/SKILL.md

Week of Nov 2, 2026 · Line counts unavailable

Before Not checked yet → After Network or broad shell

First observation → 75f49e7bf30c

No earlier version was observed for comparison.

Compare on GitHub

group_skills/infra_dataops_group_skills/aiops_capacity_planning_agent/SKILL.md

Week of Nov 2, 2026 · Line counts unavailable

Before Not checked yet → After Instructions only

First observation → 75f49e7bf30c

No earlier version was observed for comparison.

Compare on GitHub

group_skills/infra_dataops_group_skills/aiops_infrastructure_anomaly_detection/SKILL.md

Week of Nov 2, 2026 · Line counts unavailable

Before Not checked yet → After Instructions only

First observation → 75f49e7bf30c

No earlier version was observed for comparison.

Compare on GitHub

group_skills/infra_dataops_group_skills/aiops_observability_copilot/SKILL.md

Week of Nov 2, 2026 · Line counts unavailable

Before Not checked yet → After Instructions only

First observation → 75f49e7bf30c

No earlier version was observed for comparison.

Compare on GitHub

group_skills/infra_dataops_group_skills/aiops_platform_optimization_agent/SKILL.md

Week of Nov 2, 2026 · Line counts unavailable

Before Not checked yet → After Instructions only

First observation → 75f49e7bf30c

No earlier version was observed for comparison.

Compare on GitHub

group_skills/infra_dataops_group_skills/aiops_query_cost_analyzer/SKILL.md

Week of Nov 2, 2026 · Line counts unavailable

Before Not checked yet → After Instructions only

First observation → 75f49e7bf30c

No earlier version was observed for comparison.

Compare on GitHub

group_skills/infra_dataops_group_skills/dataops_airflow_cost_optimizer/SKILL.md

Week of Nov 2, 2026 · Line counts unavailable

Before Not checked yet → After Instructions only

First observation → 75f49e7bf30c

No earlier version was observed for comparison.

Compare on GitHub

group_skills/infra_dataops_group_skills/dataops_airflow_ha_review/SKILL.md

Week of Nov 2, 2026 · Line counts unavailable

Before Not checked yet → After Instructions only

First observation → 75f49e7bf30c

No earlier version was observed for comparison.

Compare on GitHub

group_skills/infra_dataops_group_skills/dataops_airflow_observability/SKILL.md

Week of Nov 2, 2026 · Line counts unavailable

Before Not checked yet → After Instructions only

First observation → 75f49e7bf30c

No earlier version was observed for comparison.

Compare on GitHub

group_skills/infra_dataops_group_skills/dataops_airflow_production_readiness/SKILL.md

Week of Nov 2, 2026 · Line counts unavailable

Before Not checked yet → After Network or broad shell

First observation → 75f49e7bf30c

No earlier version was observed for comparison.

Compare on GitHub

group_skills/infra_dataops_group_skills/dataops_blue_green_deployment/SKILL.md

Week of Nov 2, 2026 · Line counts unavailable

Before Not checked yet → After Network or broad shell

First observation → 75f49e7bf30c

No earlier version was observed for comparison.

Compare on GitHub

group_skills/infra_dataops_group_skills/dataops_cicd_pipeline_review/SKILL.md

Week of Nov 2, 2026 · Line counts unavailable

Before Not checked yet → After Instructions only

First observation → 75f49e7bf30c

No earlier version was observed for comparison.

Compare on GitHub

group_skills/infra_dataops_group_skills/dataops_disaster_recovery_review/SKILL.md

Week of Nov 2, 2026 · Line counts unavailable

Before Not checked yet → After Instructions only

First observation → 75f49e7bf30c

No earlier version was observed for comparison.

Compare on GitHub

group_skills/infra_dataops_group_skills/dataops_github_actions_optimizer/SKILL.md

Week of Nov 2, 2026 · Line counts unavailable

Before Not checked yet → After Instructions only

First observation → 75f49e7bf30c

No earlier version was observed for comparison.

Compare on GitHub

group_skills/infra_dataops_group_skills/dataops_jenkins_modernization/SKILL.md

Week of Nov 2, 2026 · Line counts unavailable

Before Not checked yet → After Instructions only

First observation → 75f49e7bf30c

No earlier version was observed for comparison.

Compare on GitHub

group_skills/infra_dataops_group_skills/dataops_postmortem_generator/SKILL.md

Week of Nov 2, 2026 · Line counts unavailable

Before Not checked yet → After Instructions only

First observation → 75f49e7bf30c

No earlier version was observed for comparison.

Compare on GitHub

group_skills/infra_dataops_group_skills/dataops_release_readiness_review/SKILL.md

Week of Nov 2, 2026 · Line counts unavailable

Before Not checked yet → After Instructions only

First observation → 75f49e7bf30c

No earlier version was observed for comparison.

Compare on GitHub

group_skills/infra_dataops_group_skills/dataops_root_cause_analysis/SKILL.md

Week of Nov 2, 2026 · Line counts unavailable

Before Not checked yet → After Network or broad shell

First observation → 75f49e7bf30c

No earlier version was observed for comparison.

Compare on GitHub

group_skills/infra_dataops_group_skills/dataops_self_healing_platform/SKILL.md

Week of Nov 2, 2026 · Line counts unavailable

Before Not checked yet → After Instructions only

First observation → 75f49e7bf30c

No earlier version was observed for comparison.

Compare on GitHub

group_skills/infra_dataops_group_skills/dataops_sla_monitoring/SKILL.md

Week of Nov 2, 2026 · Line counts unavailable

Before Not checked yet → After Network or broad shell

First observation → 75f49e7bf30c

No earlier version was observed for comparison.

Compare on GitHub

group_skills/infra_dataops_group_skills/dataops_workflow_orchestration_review/SKILL.md

Week of Nov 2, 2026 · Line counts unavailable

Before Not checked yet → After Instructions only

First observation → 75f49e7bf30c

No earlier version was observed for comparison.

Compare on GitHub

group_skills/infra_dataops_group_skills/infra_alert_fatigue_reduction/SKILL.md

Week of Nov 2, 2026 · Line counts unavailable

Before Not checked yet → After Network or broad shell

First observation → 75f49e7bf30c

No earlier version was observed for comparison.

Compare on GitHub

group_skills/infra_dataops_group_skills/infra_aws_data_platform_review/SKILL.md

Week of Nov 2, 2026 · Line counts unavailable

Before Not checked yet → After Instructions only

First observation → 75f49e7bf30c

No earlier version was observed for comparison.

Compare on GitHub

group_skills/infra_dataops_group_skills/infra_azure_data_platform_review/SKILL.md

Week of Nov 2, 2026 · Line counts unavailable

Before Not checked yet → After Instructions only

First observation → 75f49e7bf30c

No earlier version was observed for comparison.

Compare on GitHub

group_skills/infra_dataops_group_skills/infra_compliance_readiness/SKILL.md

Week of Nov 2, 2026 · Line counts unavailable

Before Not checked yet → After Instructions only

First observation → 75f49e7bf30c

No earlier version was observed for comparison.

Compare on GitHub

group_skills/infra_dataops_group_skills/infra_docker_best_practices/SKILL.md

Week of Nov 2, 2026 · Line counts unavailable

Before Not checked yet → After Network or broad shell

First observation → 75f49e7bf30c

No earlier version was observed for comparison.

Compare on GitHub

group_skills/infra_dataops_group_skills/infra_gcp_data_platform_review/SKILL.md

Week of Nov 2, 2026 · Line counts unavailable

Before Not checked yet → After Instructions only

First observation → 75f49e7bf30c

No earlier version was observed for comparison.

Compare on GitHub

group_skills/infra_dataops_group_skills/infra_gitops_deployment_review/SKILL.md

Week of Nov 2, 2026 · Line counts unavailable

Before Not checked yet → After Instructions only

First observation → 75f49e7bf30c

No earlier version was observed for comparison.

Compare on GitHub

group_skills/infra_dataops_group_skills/infra_grafana_dashboard_review/SKILL.md

Week of Nov 2, 2026 · Line counts unavailable

Before Not checked yet → After Network or broad shell

First observation → 75f49e7bf30c

No earlier version was observed for comparison.

Compare on GitHub

group_skills/infra_dataops_group_skills/infra_kafka_cost_optimizer/SKILL.md

Week of Nov 2, 2026 · Line counts unavailable

Before Not checked yet → After Instructions only

First observation → 75f49e7bf30c

No earlier version was observed for comparison.

Compare on GitHub

group_skills/infra_dataops_group_skills/infra_kafka_platform_review/SKILL.md

Week of Nov 2, 2026 · Line counts unavailable

Before Not checked yet → After Instructions only

First observation → 75f49e7bf30c

No earlier version was observed for comparison.

Compare on GitHub

group_skills/infra_dataops_group_skills/infra_kubernetes_autoscaling_review/SKILL.md

Week of Nov 2, 2026 · Line counts unavailable

Before Not checked yet → After Instructions only

First observation → 75f49e7bf30c

No earlier version was observed for comparison.

Compare on GitHub

group_skills/infra_dataops_group_skills/infra_kubernetes_cluster_health/SKILL.md

Week of Nov 2, 2026 · Line counts unavailable

Before Not checked yet → After Instructions only

First observation → 75f49e7bf30c

No earlier version was observed for comparison.

Compare on GitHub

group_skills/infra_dataops_group_skills/infra_kubernetes_cost_optimizer/SKILL.md

Week of Nov 2, 2026 · Line counts unavailable

Before Not checked yet → After Instructions only

First observation → 75f49e7bf30c

No earlier version was observed for comparison.

Compare on GitHub

group_skills/infra_dataops_group_skills/infra_kubernetes_security_audit/SKILL.md

Week of Nov 2, 2026 · Line counts unavailable

Before Not checked yet → After Instructions only

First observation → 75f49e7bf30c

No earlier version was observed for comparison.

Compare on GitHub

group_skills/infra_dataops_group_skills/infra_kubernetes_storage_review/SKILL.md

Week of Nov 2, 2026 · Line counts unavailable

Before Not checked yet → After Instructions only

First observation → 75f49e7bf30c

No earlier version was observed for comparison.

Compare on GitHub

group_skills/infra_dataops_group_skills/infra_multi_cloud_governance/SKILL.md

Week of Nov 2, 2026 · Line counts unavailable

Before Not checked yet → After Instructions only

First observation → 75f49e7bf30c

No earlier version was observed for comparison.

Compare on GitHub

group_skills/infra_dataops_group_skills/infra_network_security_review/SKILL.md

Week of Nov 2, 2026 · Line counts unavailable

Before Not checked yet → After Instructions only

First observation → 75f49e7bf30c

No earlier version was observed for comparison.

Compare on GitHub

group_skills/infra_dataops_group_skills/infra_observability_stack_review/SKILL.md

Week of Nov 2, 2026 · Line counts unavailable

Before Not checked yet → After Network or broad shell

First observation → 75f49e7bf30c

No earlier version was observed for comparison.

Compare on GitHub

group_skills/infra_dataops_group_skills/infra_opentelemetry_instrumentation/SKILL.md

Week of Nov 2, 2026 · Line counts unavailable

Before Not checked yet → After Instructions only

First observation → 75f49e7bf30c

No earlier version was observed for comparison.

Compare on GitHub

group_skills/infra_dataops_group_skills/infra_prometheus_optimization/SKILL.md

Week of Nov 2, 2026 · Line counts unavailable

Before Not checked yet → After Network or broad shell

First observation → 75f49e7bf30c

No earlier version was observed for comparison.

Compare on GitHub

group_skills/infra_dataops_group_skills/infra_rbac_audit/SKILL.md

Week of Nov 2, 2026 · Line counts unavailable

Before Not checked yet → After Instructions only

First observation → 75f49e7bf30c

No earlier version was observed for comparison.

Compare on GitHub

group_skills/infra_dataops_group_skills/infra_secrets_management_review/SKILL.md

Week of Nov 2, 2026 · Line counts unavailable

Before Not checked yet → After Network or broad shell

First observation → 75f49e7bf30c

No earlier version was observed for comparison.

Compare on GitHub

group_skills/infra_dataops_group_skills/infra_streaming_reliability_review/SKILL.md

Week of Nov 2, 2026 · Line counts unavailable

Before Not checked yet → After Instructions only

First observation → 75f49e7bf30c

No earlier version was observed for comparison.

Compare on GitHub

group_skills/infra_dataops_group_skills/infra_terraform_cost_estimator/SKILL.md

Week of Nov 2, 2026 · Line counts unavailable

Before Not checked yet → After Network or broad shell

First observation → 75f49e7bf30c

No earlier version was observed for comparison.

Compare on GitHub

group_skills/infra_dataops_group_skills/infra_terraform_review/SKILL.md

Week of Nov 2, 2026 · Line counts unavailable

Before Not checked yet → After Instructions only

First observation → 75f49e7bf30c

No earlier version was observed for comparison.

Compare on GitHub

group_skills/infra_dataops_group_skills/infra_terraform_security_scan/SKILL.md

Week of Nov 2, 2026 · Line counts unavailable

Before Not checked yet → After Network or broad shell

First observation → 75f49e7bf30c

No earlier version was observed for comparison.

Compare on GitHub

group_skills/infra_dataops_group_skills/platform_engineering_agentic_control_plane/SKILL.md

Week of Nov 2, 2026 · Line counts unavailable

Before Not checked yet → After Instructions only

First observation → 75f49e7bf30c

No earlier version was observed for comparison.

Compare on GitHub

group_skills/infra_dataops_group_skills/platform_engineering_data_platform_api/SKILL.md

Week of Nov 2, 2026 · Line counts unavailable

Before Not checked yet → After Instructions only

First observation → 75f49e7bf30c

No earlier version was observed for comparison.

Compare on GitHub

group_skills/infra_dataops_group_skills/platform_engineering_internal_developer_platform/SKILL.md

Week of Nov 2, 2026 · Line counts unavailable

Before Not checked yet → After Instructions only

First observation → 75f49e7bf30c

No earlier version was observed for comparison.

Compare on GitHub

group_skills/starrocks_group_skills/airflow_starrocks_backfill/SKILL.md

Week of Nov 2, 2026 · Line counts unavailable

Before Not checked yet → After Instructions only

First observation → 75f49e7bf30c

No earlier version was observed for comparison.

Compare on GitHub

group_skills/starrocks_group_skills/airflow_starrocks_cdc_orchestrator/SKILL.md

Week of Nov 2, 2026 · Line counts unavailable

Before Not checked yet → After Network or broad shell

First observation → 75f49e7bf30c

No earlier version was observed for comparison.

Compare on GitHub

group_skills/starrocks_group_skills/airflow_starrocks_data_quality/SKILL.md

Week of Nov 2, 2026 · Line counts unavailable

Before Not checked yet → After Instructions only

First observation → 75f49e7bf30c

No earlier version was observed for comparison.

Compare on GitHub

group_skills/starrocks_group_skills/airflow_starrocks_etl_best_practices/SKILL.md

Week of Nov 2, 2026 · Line counts unavailable

Before Not checked yet → After Instructions only

First observation → 75f49e7bf30c

No earlier version was observed for comparison.

Compare on GitHub

group_skills/starrocks_group_skills/airflow_starrocks_pipeline/SKILL.md

Week of Nov 2, 2026 · Line counts unavailable

Before Not checked yet → After Network or broad shell

First observation → 75f49e7bf30c

No earlier version was observed for comparison.

Compare on GitHub

group_skills/starrocks_group_skills/dbt_starrocks_models/SKILL.md

Week of Nov 2, 2026 · Line counts unavailable

Before Not checked yet → After Instructions only

First observation → 75f49e7bf30c

No earlier version was observed for comparison.

Compare on GitHub

group_skills/starrocks_group_skills/dbt_starrocks_performance/SKILL.md

Week of Nov 2, 2026 · Line counts unavailable

Before Not checked yet → After Instructions only

First observation → 75f49e7bf30c

No earlier version was observed for comparison.

Compare on GitHub

group_skills/starrocks_group_skills/dbt_starrocks_production_readiness/SKILL.md

Week of Nov 2, 2026 · Line counts unavailable

Before Not checked yet → After Instructions only

First observation → 75f49e7bf30c

No earlier version was observed for comparison.

Compare on GitHub

group_skills/starrocks_group_skills/dbt_starrocks_semantic_layer/SKILL.md

Week of Nov 2, 2026 · Line counts unavailable

Before Not checked yet → After Instructions only

First observation → 75f49e7bf30c

No earlier version was observed for comparison.

Compare on GitHub

group_skills/starrocks_group_skills/dbt_starrocks_testing/SKILL.md

Week of Nov 2, 2026 · Line counts unavailable

Before Not checked yet → After Instructions only

First observation → 75f49e7bf30c

No earlier version was observed for comparison.

Compare on GitHub

group_skills/starrocks_group_skills/starrocks_admin_backup_restore/SKILL.md

Week of Nov 2, 2026 · Line counts unavailable

Before Not checked yet → After Instructions only

First observation → 75f49e7bf30c

No earlier version was observed for comparison.

Compare on GitHub

group_skills/starrocks_group_skills/starrocks_admin_cluster_health/SKILL.md

Week of Nov 2, 2026 · Line counts unavailable

Before Not checked yet → After Network or broad shell

First observation → 75f49e7bf30c

No earlier version was observed for comparison.

Compare on GitHub

group_skills/starrocks_group_skills/starrocks_admin_compaction/SKILL.md

Week of Nov 2, 2026 · Line counts unavailable

Before Not checked yet → After Network or broad shell

First observation → 75f49e7bf30c

No earlier version was observed for comparison.

Compare on GitHub

group_skills/starrocks_group_skills/starrocks_admin_query_monitor/SKILL.md

Week of Nov 2, 2026 · Line counts unavailable

Before Not checked yet → After Instructions only

First observation → 75f49e7bf30c

No earlier version was observed for comparison.

Compare on GitHub

group_skills/starrocks_group_skills/starrocks_admin_security/SKILL.md

Week of Nov 2, 2026 · Line counts unavailable

Before Not checked yet → After Instructions only

First observation → 75f49e7bf30c

No earlier version was observed for comparison.

Compare on GitHub

group_skills/starrocks_group_skills/starrocks_admin_storage_balancer/SKILL.md

Week of Nov 2, 2026 · Line counts unavailable

Before Not checked yet → After Network or broad shell

First observation → 75f49e7bf30c

No earlier version was observed for comparison.

Compare on GitHub

group_skills/starrocks_group_skills/starrocks_aggregation_optimizer/SKILL.md

Week of Nov 2, 2026 · Line counts unavailable

Before Not checked yet → After Instructions only

First observation → 75f49e7bf30c

No earlier version was observed for comparison.

Compare on GitHub

group_skills/starrocks_group_skills/starrocks_ai_incident_rca/SKILL.md

Week of Nov 2, 2026 · Line counts unavailable

Before Not checked yet → After Network or broad shell

First observation → 75f49e7bf30c

No earlier version was observed for comparison.

Compare on GitHub

group_skills/starrocks_group_skills/starrocks_ai_query_autotuner/SKILL.md

Week of Nov 2, 2026 · Line counts unavailable

Before Not checked yet → After Instructions only

First observation → 75f49e7bf30c

No earlier version was observed for comparison.

Compare on GitHub

group_skills/starrocks_group_skills/starrocks_broker_load/SKILL.md

Week of Nov 2, 2026 · Line counts unavailable

Before Not checked yet → After Instructions only

First observation → 75f49e7bf30c

No earlier version was observed for comparison.

Compare on GitHub

group_skills/starrocks_group_skills/starrocks_bucketing/SKILL.md

Week of Nov 2, 2026 · Line counts unavailable

Before Not checked yet → After Instructions only

First observation → 75f49e7bf30c

No earlier version was observed for comparison.

Compare on GitHub

group_skills/starrocks_group_skills/starrocks_cbo/SKILL.md

Week of Nov 2, 2026 · Line counts unavailable

Before Not checked yet → After Instructions only

First observation → 75f49e7bf30c

No earlier version was observed for comparison.

Compare on GitHub

group_skills/starrocks_group_skills/starrocks_cdc_pipeline/SKILL.md

Week of Nov 2, 2026 · Line counts unavailable

Before Not checked yet → After Instructions only

First observation → 75f49e7bf30c

No earlier version was observed for comparison.

Compare on GitHub

group_skills/starrocks_group_skills/starrocks_concurrency_optimizer/SKILL.md

Week of Nov 2, 2026 · Line counts unavailable

Before Not checked yet → After Instructions only

First observation → 75f49e7bf30c

No earlier version was observed for comparison.

Compare on GitHub

group_skills/starrocks_group_skills/starrocks_data_modeling/SKILL.md

Week of Nov 2, 2026 · Line counts unavailable

Before Not checked yet → After Instructions only

First observation → 75f49e7bf30c

No earlier version was observed for comparison.

Compare on GitHub

group_skills/starrocks_group_skills/starrocks_data_quality_guardian/SKILL.md

Week of Nov 2, 2026 · Line counts unavailable

Before Not checked yet → After Instructions only

First observation → 75f49e7bf30c

No earlier version was observed for comparison.

Compare on GitHub

group_skills/starrocks_group_skills/starrocks_ddl_table_types/SKILL.md

Week of Nov 2, 2026 · Line counts unavailable

Before Not checked yet → After Instructions only

First observation → 75f49e7bf30c

No earlier version was observed for comparison.

Compare on GitHub

group_skills/starrocks_group_skills/starrocks_explain_plan/SKILL.md

Week of Nov 2, 2026 · Line counts unavailable

Before Not checked yet → After Instructions only

First observation → 75f49e7bf30c

No earlier version was observed for comparison.

Compare on GitHub

group_skills/starrocks_group_skills/starrocks_files_ingestion/SKILL.md

Week of Nov 2, 2026 · Line counts unavailable

Before Not checked yet → After Instructions only

First observation → 75f49e7bf30c

No earlier version was observed for comparison.

Compare on GitHub

group_skills/starrocks_group_skills/starrocks_join_optimization/SKILL.md

Week of Nov 2, 2026 · Line counts unavailable

Before Not checked yet → After Instructions only

First observation → 75f49e7bf30c

No earlier version was observed for comparison.

Compare on GitHub

group_skills/starrocks_group_skills/starrocks_lakehouse_integration/SKILL.md

Week of Nov 2, 2026 · Line counts unavailable

Before Not checked yet → After Instructions only

First observation → 75f49e7bf30c

No earlier version was observed for comparison.

Compare on GitHub

group_skills/starrocks_group_skills/starrocks_materialized_views/SKILL.md

Week of Nov 2, 2026 · Line counts unavailable

Before Not checked yet → After Instructions only

First observation → 75f49e7bf30c

No earlier version was observed for comparison.

Compare on GitHub

group_skills/starrocks_group_skills/starrocks_medallion_architecture/SKILL.md

Week of Nov 2, 2026 · Line counts unavailable

Before Not checked yet → After Instructions only

First observation → 75f49e7bf30c

No earlier version was observed for comparison.

Compare on GitHub

group_skills/starrocks_group_skills/starrocks_memory_tuning/SKILL.md

Week of Nov 2, 2026 · Line counts unavailable

Before Not checked yet → After Network or broad shell

First observation → 75f49e7bf30c

No earlier version was observed for comparison.

Compare on GitHub

group_skills/starrocks_group_skills/starrocks_partitioning/SKILL.md

Week of Nov 2, 2026 · Line counts unavailable

Before Not checked yet → After Instructions only

First observation → 75f49e7bf30c

No earlier version was observed for comparison.

Compare on GitHub

group_skills/starrocks_group_skills/starrocks_query_optimizer/SKILL.md

Week of Nov 2, 2026 · Line counts unavailable

Before Not checked yet → After Network or broad shell

First observation → 75f49e7bf30c

No earlier version was observed for comparison.

Compare on GitHub

group_skills/starrocks_group_skills/starrocks_realtime_analytics/SKILL.md

Week of Nov 2, 2026 · Line counts unavailable

Before Not checked yet → After Instructions only

First observation → 75f49e7bf30c

No earlier version was observed for comparison.

Compare on GitHub

group_skills/starrocks_group_skills/starrocks_realtime_modeling/SKILL.md

Week of Nov 2, 2026 · Line counts unavailable

Before Not checked yet → After Network or broad shell

First observation → 75f49e7bf30c

No earlier version was observed for comparison.

Compare on GitHub

group_skills/starrocks_group_skills/starrocks_routine_load_kafka/SKILL.md

Week of Nov 2, 2026 · Line counts unavailable

Before Not checked yet → After Network or broad shell

First observation → 75f49e7bf30c

No earlier version was observed for comparison.

Compare on GitHub

group_skills/starrocks_group_skills/starrocks_schema_evolution/SKILL.md

Week of Nov 2, 2026 · Line counts unavailable

Before Not checked yet → After Instructions only

First observation → 75f49e7bf30c

No earlier version was observed for comparison.

Compare on GitHub

group_skills/starrocks_group_skills/starrocks_self_healing/SKILL.md

Week of Nov 2, 2026 · Line counts unavailable

Before Not checked yet → After Instructions only

First observation → 75f49e7bf30c

No earlier version was observed for comparison.

Compare on GitHub

group_skills/starrocks_group_skills/starrocks_stream_load/SKILL.md

Week of Nov 2, 2026 · Line counts unavailable

Before Not checked yet → After Network or broad shell

First observation → 75f49e7bf30c

No earlier version was observed for comparison.

Compare on GitHub

group_skills/trino_group_skills/trino_admin_cluster_health/SKILL.md

Week of Nov 2, 2026 · Line counts unavailable

Before Not checked yet → After Network or broad shell

First observation → 75f49e7bf30c

No earlier version was observed for comparison.

Compare on GitHub

group_skills/trino_group_skills/trino_airflow_lakehouse_pipelines/SKILL.md

Week of Nov 2, 2026 · Line counts unavailable

Before Not checked yet → After Instructions only

First observation → 75f49e7bf30c

No earlier version was observed for comparison.

Compare on GitHub

group_skills/trino_group_skills/trino_airflow_orchestration/SKILL.md

Week of Nov 2, 2026 · Line counts unavailable

Before Not checked yet → After Instructions only

First observation → 75f49e7bf30c

No earlier version was observed for comparison.

Compare on GitHub

group_skills/trino_group_skills/trino_cost_optimization/SKILL.md

Week of Nov 2, 2026 · Line counts unavailable

Before Not checked yet → After Instructions only

First observation → 75f49e7bf30c

No earlier version was observed for comparison.

Compare on GitHub

group_skills/trino_group_skills/trino_dbt_platform/SKILL.md

Week of Nov 2, 2026 · Line counts unavailable

Before Not checked yet → After Instructions only

First observation → 75f49e7bf30c

No earlier version was observed for comparison.

Compare on GitHub

group_skills/trino_group_skills/trino_dbt_query_performance/SKILL.md

Week of Nov 2, 2026 · Line counts unavailable

Before Not checked yet → After Instructions only

First observation → 75f49e7bf30c

No earlier version was observed for comparison.

Compare on GitHub

group_skills/trino_group_skills/trino_docker_compose_stack/SKILL.md

Week of Nov 2, 2026 · Line counts unavailable

Before Not checked yet → After Network or broad shell

First observation → 75f49e7bf30c

No earlier version was observed for comparison.

Compare on GitHub

group_skills/trino_group_skills/trino_explain_plan_review/SKILL.md

Week of Nov 2, 2026 · Line counts unavailable

Before Not checked yet → After Instructions only

First observation → 75f49e7bf30c

No earlier version was observed for comparison.

Compare on GitHub

group_skills/trino_group_skills/trino_federated_query_architecture/SKILL.md

Week of Nov 2, 2026 · Line counts unavailable

Before Not checked yet → After Instructions only

First observation → 75f49e7bf30c

No earlier version was observed for comparison.

Compare on GitHub

group_skills/trino_group_skills/trino_file_layout_optimization/SKILL.md

Week of Nov 2, 2026 · Line counts unavailable

Before Not checked yet → After Instructions only

First observation → 75f49e7bf30c

No earlier version was observed for comparison.

Compare on GitHub

group_skills/trino_group_skills/trino_iceberg_best_practices/SKILL.md

Week of Nov 2, 2026 · Line counts unavailable

Before Not checked yet → After Instructions only

First observation → 75f49e7bf30c

No earlier version was observed for comparison.

Compare on GitHub

group_skills/trino_group_skills/trino_lakehouse_platform_architect/SKILL.md

Week of Nov 2, 2026 · Line counts unavailable

Before Not checked yet → After Instructions only

First observation → 75f49e7bf30c

No earlier version was observed for comparison.

Compare on GitHub

group_skills/trino_group_skills/trino_memory_and_spill_tuning/SKILL.md

Week of Nov 2, 2026 · Line counts unavailable

Before Not checked yet → After Network or broad shell

First observation → 75f49e7bf30c

No earlier version was observed for comparison.

Compare on GitHub

group_skills/trino_group_skills/trino_modern_data_stack_reference_architecture/SKILL.md

Week of Nov 2, 2026 · Line counts unavailable

Before Not checked yet → After Network or broad shell

First observation → 75f49e7bf30c

No earlier version was observed for comparison.

Compare on GitHub

group_skills/trino_group_skills/trino_observability_platform/SKILL.md

Week of Nov 2, 2026 · Line counts unavailable

Before Not checked yet → After Network or broad shell

First observation → 75f49e7bf30c

No earlier version was observed for comparison.

Compare on GitHub

group_skills/trino_group_skills/trino_production_readiness_review/SKILL.md

Week of Nov 2, 2026 · Line counts unavailable

Before Not checked yet → After Network or broad shell

First observation → 75f49e7bf30c

No earlier version was observed for comparison.

Compare on GitHub

group_skills/trino_group_skills/trino_query_optimization/SKILL.md

Week of Nov 2, 2026 · Line counts unavailable

Before Not checked yet → After Instructions only

First observation → 75f49e7bf30c

No earlier version was observed for comparison.

Compare on GitHub

group_skills/trino_group_skills/trino_resource_group_governance/SKILL.md

Week of Nov 2, 2026 · Line counts unavailable

Before Not checked yet → After Network or broad shell

First observation → 75f49e7bf30c

No earlier version was observed for comparison.

Compare on GitHub

group_skills/trino_group_skills/trino_security_and_governance/SKILL.md

Week of Nov 2, 2026 · Line counts unavailable

Before Not checked yet → After Instructions only

First observation → 75f49e7bf30c

No earlier version was observed for comparison.

Compare on GitHub

group_skills/trino_group_skills/trino_self_healing_platform/SKILL.md

Week of Nov 2, 2026 · Line counts unavailable

Before Not checked yet → After Network or broad shell

First observation → 75f49e7bf30c

No earlier version was observed for comparison.

Compare on GitHub

skills/airbyte/SKILL.md

Week of Nov 2, 2026 · Line counts unavailable

Before Not checked yet → After Network or broad shell

First observation → 75f49e7bf30c

No earlier version was observed for comparison.

Compare on GitHub

skills/airflow_dag_factory/SKILL.md

Week of Nov 2, 2026 · Line counts unavailable

Before Not checked yet → After Instructions only

First observation → 75f49e7bf30c

No earlier version was observed for comparison.

Compare on GitHub

skills/airflow_dags/SKILL.md

Week of Nov 2, 2026 · Line counts unavailable

Before Not checked yet → After Network or broad shell

First observation → 75f49e7bf30c

No earlier version was observed for comparison.

Compare on GitHub

skills/apache_flink/SKILL.md

Week of Nov 2, 2026 · Line counts unavailable

Before Not checked yet → After Network or broad shell

First observation → 75f49e7bf30c

No earlier version was observed for comparison.

Compare on GitHub

skills/apache_kafka/SKILL.md

Week of Nov 2, 2026 · Line counts unavailable

Before Not checked yet → After Network or broad shell

First observation → 75f49e7bf30c

No earlier version was observed for comparison.

Compare on GitHub

skills/cdc_debezium/SKILL.md

Week of Nov 2, 2026 · Line counts unavailable

Before Not checked yet → After Network or broad shell

First observation → 75f49e7bf30c

No earlier version was observed for comparison.

Compare on GitHub

skills/clickhouse_olap/SKILL.md

Week of Nov 2, 2026 · Line counts unavailable

Before Not checked yet → After Instructions only

First observation → 75f49e7bf30c

No earlier version was observed for comparison.

Compare on GitHub

skills/dagster_assets/SKILL.md

Week of Nov 2, 2026 · Line counts unavailable

Before Not checked yet → After Instructions only

First observation → 75f49e7bf30c

No earlier version was observed for comparison.

Compare on GitHub

skills/data_contracts/SKILL.md

Week of Nov 2, 2026 · Line counts unavailable

Before Not checked yet → After Network or broad shell

First observation → 75f49e7bf30c

No earlier version was observed for comparison.

Compare on GitHub

skills/data_vault_2/SKILL.md

Week of Nov 2, 2026 · Line counts unavailable

Before Not checked yet → After Instructions only

First observation → 75f49e7bf30c

No earlier version was observed for comparison.

Compare on GitHub

skills/datahub_catalog/SKILL.md

Week of Nov 2, 2026 · Line counts unavailable

Before Not checked yet → After Network or broad shell

First observation → 75f49e7bf30c

No earlier version was observed for comparison.

Compare on GitHub

skills/dbt_core/SKILL.md

Week of Nov 2, 2026 · Line counts unavailable

Before Not checked yet → After Instructions only

First observation → 75f49e7bf30c

No earlier version was observed for comparison.

Compare on GitHub

skills/dbt_macros/SKILL.md

Week of Nov 2, 2026 · Line counts unavailable

Before Not checked yet → After Instructions only

First observation → 75f49e7bf30c

No earlier version was observed for comparison.

Compare on GitHub

skills/dbt_trino/SKILL.md

Week of Nov 2, 2026 · Line counts unavailable

Before Not checked yet → After Instructions only

First observation → 75f49e7bf30c

No earlier version was observed for comparison.

Compare on GitHub

skills/de_adr/SKILL.md

Week of Nov 2, 2026 · Line counts unavailable

Before Not checked yet → After Instructions only

First observation → 75f49e7bf30c

No earlier version was observed for comparison.

Compare on GitHub

skills/de_cost_optimization/SKILL.md

Week of Nov 2, 2026 · Line counts unavailable

Before Not checked yet → After Network or broad shell

First observation → 75f49e7bf30c

No earlier version was observed for comparison.

Compare on GitHub

skills/de_postmortem/SKILL.md

Week of Nov 2, 2026 · Line counts unavailable

Before Not checked yet → After Network or broad shell

First observation → 75f49e7bf30c

No earlier version was observed for comparison.

Compare on GitHub

skills/de_production_readiness/SKILL.md

Week of Nov 2, 2026 · Line counts unavailable

Before Not checked yet → After Network or broad shell

First observation → 75f49e7bf30c

No earlier version was observed for comparison.

Compare on GitHub

skills/de_rca/SKILL.md

Week of Nov 2, 2026 · Line counts unavailable

Before Not checked yet → After Network or broad shell

First observation → 75f49e7bf30c

No earlier version was observed for comparison.

Compare on GitHub

skills/delta_lake/SKILL.md

Week of Nov 2, 2026 · Line counts unavailable

Before Not checked yet → After Instructions only

First observation → 75f49e7bf30c

No earlier version was observed for comparison.

Compare on GitHub

skills/docker_data_envs/SKILL.md

Week of Nov 2, 2026 · Line counts unavailable

Before Not checked yet → After Network or broad shell

First observation → 75f49e7bf30c

No earlier version was observed for comparison.

Compare on GitHub

skills/duckdb/SKILL.md

Week of Nov 2, 2026 · Line counts unavailable

Before Not checked yet → After Network or broad shell

First observation → 75f49e7bf30c

No earlier version was observed for comparison.

Compare on GitHub

skills/feature_store/SKILL.md

Week of Nov 2, 2026 · Line counts unavailable

Before Not checked yet → After Network or broad shell

First observation → 75f49e7bf30c

No earlier version was observed for comparison.

Compare on GitHub

skills/github_actions_dataops/SKILL.md

Week of Nov 2, 2026 · Line counts unavailable

Before Not checked yet → After Network or broad shell

First observation → 75f49e7bf30c

No earlier version was observed for comparison.

Compare on GitHub

skills/great_expectations/SKILL.md

Week of Nov 2, 2026 · Line counts unavailable

Before Not checked yet → After Instructions only

First observation → 75f49e7bf30c

No earlier version was observed for comparison.

Compare on GitHub

skills/kimball_data_modeling/SKILL.md

Week of Nov 2, 2026 · Line counts unavailable

Before Not checked yet → After Instructions only

First observation → 75f49e7bf30c

No earlier version was observed for comparison.

Compare on GitHub

skills/kubernetes_data/SKILL.md

Week of Nov 2, 2026 · Line counts unavailable

Before Not checked yet → After Instructions only

First observation → 75f49e7bf30c

No earlier version was observed for comparison.

Compare on GitHub

skills/mage_ai/SKILL.md

Week of Nov 2, 2026 · Line counts unavailable

Before Not checked yet → After Network or broad shell

First observation → 75f49e7bf30c

No earlier version was observed for comparison.

Compare on GitHub

skills/mcp_server/SKILL.md

Week of Nov 2, 2026 · Line counts unavailable

Before Not checked yet → After Instructions only

First observation → 75f49e7bf30c

No earlier version was observed for comparison.

Compare on GitHub

skills/medallion_architecture/SKILL.md

Week of Nov 2, 2026 · Line counts unavailable

Before Not checked yet → After Instructions only

First observation → 75f49e7bf30c

No earlier version was observed for comparison.

Compare on GitHub

skills/mlflow_pipelines/SKILL.md

Week of Nov 2, 2026 · Line counts unavailable

Before Not checked yet → After Network or broad shell

First observation → 75f49e7bf30c

No earlier version was observed for comparison.

Compare on GitHub

skills/openlineage/SKILL.md

Week of Nov 2, 2026 · Line counts unavailable

Before Not checked yet → After Network or broad shell

First observation → 75f49e7bf30c

No earlier version was observed for comparison.

Compare on GitHub

skills/postgresql_de/SKILL.md

Week of Nov 2, 2026 · Line counts unavailable

Before Not checked yet → After Instructions only

First observation → 75f49e7bf30c

No earlier version was observed for comparison.

Compare on GitHub

skills/prefect_workflows/SKILL.md

Week of Nov 2, 2026 · Line counts unavailable

Before Not checked yet → After Network or broad shell

First observation → 75f49e7bf30c

No earlier version was observed for comparison.

Compare on GitHub

skills/pyspark_etl/SKILL.md

Week of Nov 2, 2026 · Line counts unavailable

Before Not checked yet → After Instructions only

First observation → 75f49e7bf30c

No earlier version was observed for comparison.

Compare on GitHub

skills/pyspark_streaming/SKILL.md

Week of Nov 2, 2026 · Line counts unavailable

Before Not checked yet → After Instructions only

First observation → 75f49e7bf30c

No earlier version was observed for comparison.

Compare on GitHub

skills/rag_pipeline/SKILL.md

Week of Nov 2, 2026 · Line counts unavailable

Before Not checked yet → After Instructions only

First observation → 75f49e7bf30c

No earlier version was observed for comparison.

Compare on GitHub

skills/ray_data/SKILL.md

Week of Nov 2, 2026 · Line counts unavailable

Before Not checked yet → After Instructions only

First observation → 75f49e7bf30c

No earlier version was observed for comparison.

Compare on GitHub

skills/redpanda/SKILL.md

Week of Nov 2, 2026 · Line counts unavailable

Before Not checked yet → After Network or broad shell

First observation → 75f49e7bf30c

No earlier version was observed for comparison.

Compare on GitHub

skills/soda_core/SKILL.md

Week of Nov 2, 2026 · Line counts unavailable

Before Not checked yet → After Instructions only

First observation → 75f49e7bf30c

No earlier version was observed for comparison.

Compare on GitHub

skills/spark_sql/SKILL.md

Week of Nov 2, 2026 · Line counts unavailable

Before Not checked yet → After Instructions only

First observation → 75f49e7bf30c

No earlier version was observed for comparison.

Compare on GitHub

skills/sqlfluff/SKILL.md

Week of Nov 2, 2026 · Line counts unavailable

Before Not checked yet → After Network or broad shell

First observation → 75f49e7bf30c

No earlier version was observed for comparison.

Compare on GitHub

skills/sqlmesh/SKILL.md

Week of Nov 2, 2026 · Line counts unavailable

Before Not checked yet → After Instructions only

First observation → 75f49e7bf30c

No earlier version was observed for comparison.

Compare on GitHub

skills/terraform_data/SKILL.md

Week of Nov 2, 2026 · Line counts unavailable

Before Not checked yet → After Instructions only

First observation → 75f49e7bf30c

No earlier version was observed for comparison.

Compare on GitHub

skills/trino_iceberg/SKILL.md

Week of Nov 2, 2026 · Line counts unavailable

Before Not checked yet → After Instructions only

First observation → 75f49e7bf30c

No earlier version was observed for comparison.

Compare on GitHub

skills/vertica/SKILL.md

Week of Nov 2, 2026 · Line counts unavailable

Before Not checked yet → After Instructions only

First observation → 75f49e7bf30c

No earlier version was observed for comparison.

Compare on GitHub

skills/vertica_query_optimization/SKILL.md

Week of Nov 2, 2026 · Line counts unavailable

Before Not checked yet → After Instructions only

First observation → 75f49e7bf30c

No earlier version was observed for comparison.

Compare on GitHub

View on GitHubAdd to my skills

Verified commit 75f49e7bf30c9908a0921911755abb6cc6c01f7b

git clone --filter=blob:none --no-checkout https://github.com/ivanshamaev/de-agent-skills.git .hotskills/ivanshamaev-de-agent-skills && git -C .hotskills/ivanshamaev-de-agent-skills checkout --detach 75f49e7bf30c9908a0921911755abb6cc6c01f7b # Copy each selected skill directory from .hotskills/ivanshamaev-de-agent-skills into .claude/skills/<skill-name>/
24GitHub stars
2stars in 7 days
159skills in this repository
0commits in 30 days

Heat

2.4
  • Star growth, last 7 daysNot available
  • Star growth, last 24 hoursNot available
  • Rank movement, last 7 daysNot available
  • Commits, last 30 daysNot available
  • Accounts asking about it through MCP, last 7 daysNot available
  • Hot votes this weekNot available

Heat never changes the order by stars, and sponsorship never touches it. How heat works

Stars over time

Oct 25, 2026Nov 4, 202624

30-day change not yet available: not enough history.

Individual skills in this repository

How it works

aiops-autonomous-incident-response

When your agent uses it

AIOps autonomous incident response agent — LLM-driven diagnosis loop (Claude tool-use agent with kubectl/SQL/Prometheus tools), alert-to-action pipeline (PagerDuty webhook → agent trigger), automated RCA generation (failure taxonomy + log correlation), self-healing action executor with approval gate, incident severity classification, runbook automation (structured YAML runbooks executed by agent), escalation logic, incident timeline auto-generation, Slack integration for human-in-the-loop approvals

What it loads into context

Frontmatter

103 tokens

Always available to the agent

SKILL.md

3,360 tokens

When the skill is activated

Reference documents

0 tokens

Loaded on request

Token counts are estimates. Scripts run separately; they are not counted as reference context.

The playbook

  1. When to Use
  2. Architecture Overview
  3. Tool Definitions for Incident Agent
  4. Tool Executor
  5. Incident Response Agent Loop
  6. Alert Webhook Trigger
  7. Slack Approval Gate
  8. Anti-Patterns
  9. References

Files

  • SKILL.mdcore15,177 bytes
  • SKILL.mdcore15,177 bytes
  • SKILL.mdcore15,177 bytes
  • SKILL.mdcore15,177 bytes
  • SKILL.mdcore15,177 bytes
  • SKILL.mdcore15,177 bytes
  • SKILL.mdcore15,177 bytes
  • SKILL.mdcore15,177 bytes

No excerpt is shown for this license. Read the source on GitHub.

View the complete source on GitHub

Skills included

  • aiops-autonomous-incident-response
  • aiops-capacity-planning-agent
  • aiops-infrastructure-anomaly-detection
  • aiops-observability-copilot
  • aiops-platform-optimization-agent
  • aiops-query-cost-analyzer
  • dataops-airflow-cost-optimizer
  • dataops-airflow-ha-review
  • dataops-airflow-observability
  • dataops-airflow-production-readiness
  • dataops-blue-green-deployment
  • dataops-cicd-pipeline-review
  • dataops-disaster-recovery-review
  • dataops-github-actions-optimizer
  • dataops-jenkins-modernization
  • dataops-postmortem-generator
  • dataops-release-readiness-review
  • dataops-root-cause-analysis
  • dataops-self-healing-platform
  • dataops-sla-monitoring
  • dataops-workflow-orchestration-review
  • infra-alert-fatigue-reduction
  • infra-aws-data-platform-review
  • infra-azure-data-platform-review
  • infra-compliance-readiness
  • infra-docker-best-practices
  • infra-gcp-data-platform-review
  • infra-gitops-deployment-review
  • infra-grafana-dashboard-review
  • infra-kafka-cost-optimizer
  • infra-kafka-platform-review
  • infra-kubernetes-autoscaling-review
  • infra-kubernetes-cluster-health
  • infra-kubernetes-cost-optimizer
  • infra-kubernetes-security-audit
  • infra-kubernetes-storage-review
  • infra-multi-cloud-governance
  • infra-network-security-review
  • infra-observability-stack-review
  • infra-opentelemetry-instrumentation
  • infra-prometheus-optimization
  • infra-rbac-audit
  • infra-secrets-management-review
  • infra-streaming-reliability-review
  • infra-terraform-cost-estimator
  • infra-terraform-review
  • infra-terraform-security-scan
  • platform-engineering-agentic-control-plane
  • platform-engineering-data-platform-api
  • platform-engineering-internal-developer-platform
  • airflow-starrocks-backfill
  • airflow-starrocks-cdc-orchestrator
  • airflow-starrocks-data-quality
  • airflow-starrocks-etl-best-practices
  • airflow-starrocks-pipeline
  • dbt-starrocks-models
  • dbt-starrocks-performance
  • dbt-starrocks-production-readiness
  • dbt-starrocks-semantic-layer
  • dbt-starrocks-testing
  • starrocks-admin-backup-restore
  • starrocks-admin-cluster-health
  • starrocks-admin-compaction
  • starrocks-admin-query-monitor
  • starrocks-admin-security
  • starrocks-admin-storage-balancer
  • starrocks-aggregation-optimizer
  • starrocks-ai-incident-rca
  • starrocks-ai-query-autotuner
  • starrocks-broker-load
  • starrocks-bucketing
  • starrocks-cbo
  • starrocks-cdc-pipeline
  • starrocks-concurrency-optimizer
  • starrocks-data-modeling
  • starrocks-data-quality-guardian
  • starrocks-ddl-table-types
  • starrocks-explain-plan
  • starrocks-files-ingestion
  • starrocks-join-optimization
  • starrocks-lakehouse-integration
  • starrocks-materialized-views
  • starrocks-medallion-architecture
  • starrocks-memory-tuning
  • starrocks-partitioning
  • starrocks-query-optimizer
  • starrocks-realtime-analytics
  • starrocks-realtime-modeling
  • starrocks-routine-load-kafka
  • starrocks-schema-evolution
  • starrocks-self-healing
  • starrocks-stream-load
  • trino-admin-cluster-health
  • trino-airflow-lakehouse-pipelines
  • trino-airflow-orchestration
  • trino-cost-optimization
  • trino-dbt-platform
  • trino-dbt-query-performance
  • trino-docker-compose-stack
  • trino-explain-plan-review
  • trino-federated-query-architecture
  • trino-file-layout-optimization
  • trino-iceberg-best-practices
  • trino-lakehouse-platform-architect
  • trino-memory-and-spill-tuning
  • trino-modern-data-stack-reference-architecture
  • trino-observability-platform
  • trino-production-readiness-review
  • trino-query-optimization
  • trino-resource-group-governance
  • trino-security-and-governance
  • trino-self-healing-platform
  • airbyte
  • airflow_dag_factory
  • airflow-dags
  • apache-flink
  • apache-kafka
  • cdc-debezium
  • clickhouse-olap
  • dagster-assets
  • data-contracts
  • data_vault_2
  • datahub-catalog
  • dbt-core
  • dbt-macros
  • dbt_trino
  • de-architecture-decision
  • de-cost-optimization
  • de-postmortem-writer
  • de-production-readiness
  • de-root-cause-analysis
  • delta-lake
  • docker-data-environments
  • duckdb
  • feature-store
  • github-actions-dataops
  • great-expectations
  • kimball_data_modeling
  • kubernetes-data-platform
  • mage-ai-pipelines
  • mcp-server
  • medallion_architecture
  • mlflow-data-pipelines
  • openlineage
  • postgresql-data-engineering
  • prefect-workflows
  • pyspark_etl
  • pyspark-structured-streaming
  • rag-data-pipeline
  • ray-data
  • redpanda
  • soda-core
  • spark_sql
  • sqlfluff
  • sqlmesh
  • terraform-data-infrastructure
  • trino_iceberg
  • vertica
  • vertica_query_optimization

Repository facts

License
No license detected
Created
May 5, 2026
Last pushed
May 19, 2026
Forks
1
Open issues
0
Project activity
Slowing

Before you install

Network or broad shell

Automated signals, not a guarantee

Checked Nov 6, 2026

Not fully analyzed: some files were too long, unreadable or missing. This never lowers the level.

Show 1,543 notes
  • group_skills/infra_dataops_group_skills/aiops_autonomous_incident_response/SKILL.md:1 Analysis incomplete: Referenced executable target unavailable; not analyzed
  • group_skills/infra_dataops_group_skills/aiops_autonomous_incident_response/SKILL.md:1 Analysis incomplete: Referenced executable target unavailable; not analyzed
  • group_skills/infra_dataops_group_skills/aiops_autonomous_incident_response/SKILL.md:1 Analysis incomplete: Referenced executable target unavailable; not analyzed
  • group_skills/infra_dataops_group_skills/aiops_autonomous_incident_response/SKILL.md:1 Analysis incomplete: Referenced executable target unavailable; not analyzed
  • group_skills/infra_dataops_group_skills/aiops_autonomous_incident_response/SKILL.md:1 Analysis incomplete: Referenced executable target unavailable; not analyzed
  • group_skills/infra_dataops_group_skills/aiops_autonomous_incident_response/SKILL.md:1 Analysis incomplete: Referenced executable target unavailable; not analyzed
  • group_skills/infra_dataops_group_skills/aiops_autonomous_incident_response/SKILL.md:1 Analysis incomplete: Referenced executable target unavailable; not analyzed
  • group_skills/infra_dataops_group_skills/aiops_capacity_planning_agent/SKILL.md:1 Analysis incomplete: Referenced executable target unavailable; not analyzed
  • group_skills/infra_dataops_group_skills/aiops_capacity_planning_agent/SKILL.md:1 Analysis incomplete: Referenced executable target unavailable; not analyzed
  • group_skills/infra_dataops_group_skills/aiops_capacity_planning_agent/SKILL.md:1 Analysis incomplete: Referenced executable target unavailable; not analyzed
  • group_skills/infra_dataops_group_skills/aiops_capacity_planning_agent/SKILL.md:1 Analysis incomplete: Referenced executable target unavailable; not analyzed
  • group_skills/infra_dataops_group_skills/aiops_capacity_planning_agent/SKILL.md:1 Analysis incomplete: Referenced executable target unavailable; not analyzed
  • group_skills/infra_dataops_group_skills/aiops_capacity_planning_agent/SKILL.md:1 Analysis incomplete: Referenced executable target unavailable; not analyzed
  • group_skills/infra_dataops_group_skills/aiops_infrastructure_anomaly_detection/SKILL.md:1 Analysis incomplete: Referenced executable target unavailable; not analyzed
  • group_skills/infra_dataops_group_skills/aiops_infrastructure_anomaly_detection/SKILL.md:1 Analysis incomplete: Referenced executable target unavailable; not analyzed
  • group_skills/infra_dataops_group_skills/aiops_infrastructure_anomaly_detection/SKILL.md:1 Analysis incomplete: Referenced executable target unavailable; not analyzed
  • group_skills/infra_dataops_group_skills/aiops_infrastructure_anomaly_detection/SKILL.md:1 Analysis incomplete: Referenced executable target unavailable; not analyzed
  • group_skills/infra_dataops_group_skills/aiops_infrastructure_anomaly_detection/SKILL.md:1 Analysis incomplete: Referenced executable target unavailable; not analyzed
  • group_skills/infra_dataops_group_skills/aiops_observability_copilot/SKILL.md:1 Analysis incomplete: Referenced executable target unavailable; not analyzed
  • group_skills/infra_dataops_group_skills/aiops_observability_copilot/SKILL.md:1 Analysis incomplete: Referenced executable target unavailable; not analyzed
Show all 1,412 signals by file

group_skills/infra_dataops_group_skills/aiops_autonomous_incident_response/SKILL.md

  • Network accessline 140
    import requests         minutes = tool_input.get("lookback_minutes", 30)         resp = requests.get(
  • Network accessline 141
    minutes = tool_input.get("lookback_minutes", 30)         resp = requests.get(             f"{PROMETHEUS_URL}/api/v1/query",
  • Network accessline 142
    resp = requests.get(
  • Network accessline 368
    requests.post(SLACK_WEBHOOK, json=message)

group_skills/infra_dataops_group_skills/dataops_airflow_ha_review/SKILL.md

  • Network accessline 99
    gitSync:     enabled: true     repo: https://github.com/my-org/airflow-dags
  • Network accessline 100
    enabled: true     repo: https://github.com/my-org/airflow-dags     branch: main
  • Network accessline 101
    repo: https://github.com/my-org/airflow-dags

group_skills/infra_dataops_group_skills/dataops_airflow_observability/SKILL.md

  • Network accessline 235
    annotations:         summary: "Airflow scheduler not heartbeating"         runbook: "https://wiki.my-org.com/runbooks/airflow-scheduler-down"
  • Network accessline 237
    runbook: "https://wiki.my-org.com/runbooks/airflow-scheduler-down"

group_skills/infra_dataops_group_skills/dataops_airflow_production_readiness/SKILL.md

  • Network accessline 179
    task_id="spark_submit",     image="apache/spark:3.5.0",     cmds=["spark-submit", "--master", "k8s://https://kubernetes.default.svc"],
  • Network accessline 180
    image="apache/spark:3.5.0",     cmds=["spark-submit", "--master", "k8s://https://kubernetes.default.svc"],     resources=k8s.V1ResourceRequirements(
  • Network accessline 181
    cmds=["spark-submit", "--master", "k8s://https://kubernetes.default.svc"],     resources=k8s.V1ResourceRequirements(         requests={"cpu": "2", "memory": "8Gi"},
  • Network accessline 259
    # Airflow health endpoint (liveness probe) curl http://airflow-webserver:8080/health
  • Network accessline 260
    curl http://airflow-webserver:8080/health

group_skills/infra_dataops_group_skills/dataops_blue_green_deployment/SKILL.md

  • Network accessline 97
    -o jsonpath='{.items[0].metadata.name}') kubectl exec -n $NAMESPACE $GREEN_POD -- \   curl -sf http://localhost:8080/health || { echo "Smoke test FAILED"; exit 1; }
  • Network accessline 98
    kubectl exec -n $NAMESPACE $GREEN_POD --    curl -sf http://localhost:8080/health || { echo "Smoke test FAILED"; exit 1; }
  • Network accessline 99
    curl -sf http://localhost:8080/health || { echo "Smoke test FAILED"; exit 1; }

group_skills/infra_dataops_group_skills/dataops_cicd_pipeline_review/SKILL.md

  • Network accessline 163
    environment:     name: production      # GitHub environment with required reviewers     url: https://airflow.prod.my-company.com
  • Network accessline 164
    name: production      # GitHub environment with required reviewers     url: https://airflow.prod.my-company.com   steps:
  • Network accessline 165
    url: https://airflow.prod.my-company.com

group_skills/infra_dataops_group_skills/dataops_jenkins_modernization/SKILL.md

  • Network accessline 291
    - kubernetes:         name: "kubernetes"         serverUrl: "https://kubernetes.default.svc"
  • Network accessline 292
    name: "kubernetes"         serverUrl: "https://kubernetes.default.svc"         namespace: "jenkins"
  • Network accessline 293
    serverUrl: "https://kubernetes.default.svc"
  • Network accessline 294
    namespace: "jenkins"         jenkinsUrl: "http://jenkins.jenkins.svc.cluster.local:8080"         podRetention: "never"
  • Network accessline 295
    jenkinsUrl: "http://jenkins.jenkins.svc.cluster.local:8080"
  • Access to secretsline 313
    [Credential-related source omitted]

group_skills/infra_dataops_group_skills/dataops_root_cause_analysis/SKILL.md

  • Network accessline 124
    # In Spark UI: Stages tab → look for tasks with >> median duration # Or from history server: curl -s http://spark-history:18080/api/v1/applications/$APP_ID/stages | \
  • Network accessline 125
    # Or from history server: curl -s http://spark-history:18080/api/v1/applications/$APP_ID/stages | \   jq '.[] | {stageId, numTasks, maxTaskDuration, medianDuration: (.taskMetrics.executorRunTime / .numTasks)}'
  • Network accessline 126
    curl -s http://spark-history:18080/api/v1/applications/$APP_ID/stages | \

group_skills/infra_dataops_group_skills/dataops_sla_monitoring/SKILL.md

  • Network accessline 257
    "type": "button",                     "text": {"type": "plain_text", "text": "View in Airflow"},                     "url": f"http://airflow.internal/dags/{dag.dag_id}/grid",
  • Network accessline 258
    "text": {"type": "plain_text", "text": "View in Airflow"},                     "url": f"http://airflow.internal/dags/{dag.dag_id}/grid",                 }]
  • Network accessline 259
    "url": f"http://airflow.internal/dags/{dag.dag_id}/grid",
  • Network accessline 265
    # Notify data-eng + all consumer channels     for channel in ["#data-eng-sla", "#analytics-alerts", "#bi-team"]:         requests.post(SLACK_WEBHOOK, json={"channel": channel, **message})
  • Network accessline 267
    requests.post(SLACK_WEBHOOK, json={"channel": channel, **message})

group_skills/infra_dataops_group_skills/infra_alert_fatigue_reduction/SKILL.md

  • Network accessline 57
    summary: "Pipeline error budget burning fast ({{ $labels.dag_id }})"         description: "At current burn rate, 1-hour error budget exhausted in 5 minutes"         runbook: "https://wiki.my-org.com/runbooks/pipeline-slo"
  • Network accessline 59
    runbook: "https://wiki.my-org.com/runbooks/pipeline-slo"
  • Network accessline 160
    summary: "Pipeline {{ $labels.dag_id }} data stale > 2h"   # REQUIRED: one-line what     description: "Last successful run: {{ $value | humanizeDuration }} ago. Check if DAG is paused or if upstream source is delayed."  # REQUIRED: context 
  • Network accessline 161
    description: "Last successful run: {{ $value | humanizeDuration }} ago. Check if DAG is paused or if upstream source is delayed."  # REQUIRED: context     runbook: "https://wiki.my-org.com/runbooks/pipeline-freshness"   # REQUIRED: what to 
  • Network accessline 162
    runbook: "https://wiki.my-org.com/runbooks/pipeline-freshness"   # REQUIRED: what to do
  • Network accessline 163
    dashboard: "https://grafana.my-org.com/d/data-platform?var-dag_id={{ $labels.dag_id }}"
  • Network accessline 198
    PROM_URL="http://prometheus:9090"
  • Network accessline 200
    # Alerts that fired most in last 7 days curl -s "${PROM_URL}/api/v1/query?query=sum(increase(ALERTS_FOR_STATE[7d])) by (alertname) > 0" \
  • Network accessline 201
    curl -s "${PROM_URL}/api/v1/query?query=sum(increase(ALERTS_FOR_STATE[7d])) by (alertname) > 0" \
  • Network accessline 205
    # Alerts firing right now (potential noise) curl -s "${PROM_URL}/api/v1/alerts" \
  • Network accessline 206
    curl -s "${PROM_URL}/api/v1/alerts" \

group_skills/infra_dataops_group_skills/infra_azure_data_platform_review/SKILL.md

  • Network accessline 237
    credential = WorkloadIdentityCredential() client = SecretClient(     vault_url="https://my-kv.vault.azure.net/",
  • Network accessline 238
    client = SecretClient(     vault_url="https://my-kv.vault.azure.net/",     credential=credential,
  • Network accessline 239
    vault_url="https://my-kv.vault.azure.net/",

group_skills/infra_dataops_group_skills/infra_docker_best_practices/SKILL.md

  • Dangerous shell operationline 70
    RUN apt-get update && apt-get install -y --no-install-recommends git      && rm -rf /var/lib/apt/lists/*
  • Dangerous shell operationline 71
    && rm -rf /var/lib/apt/lists/*
  • Network accessline 107
    # BAD: update and install in separate layers RUN apt-get update RUN apt-get install -y curl wget git
  • Network accessline 109
    RUN apt-get install -y curl wget git
  • Dangerous shell operationline 112
    RUN apt-get update      && apt-get install -y --no-install-recommends          curl          git          ca-certificates      && rm -rf /var/lib/apt/lists/*   # removes cached package lists
  • Network accessline 112
    RUN apt-get update \     && apt-get install -y --no-install-recommends \         curl \
  • Network accessline 113
    && apt-get install -y --no-install-recommends \         curl \         git \
  • Network accessline 114
    curl \
  • Dangerous shell operationline 117
    && rm -rf /var/lib/apt/lists/*   # removes cached package lists
  • Network accessline 201
    RUN --mount=type=secret,id=pip_token \     pip install --extra-index-url \     https://$(cat /run/secrets/pip_token)@pkgs.company.com/simple/ \
  • Network accessline 202
    pip install --extra-index-url \     https://$(cat /run/secrets/pip_token)@pkgs.company.com/simple/ \     my-private-package
  • Network accessline 203
    https://$(cat /run/secrets/pip_token)@pkgs.company.com/simple/ \
  • Access to secretsline 209
    [Credential-related source omitted]
  • Access to secretsline 210
    [Credential-related source omitted]
  • Access to secretsline 222
    [Credential-related source omitted]
  • Network accessline 271
    # Install Spark RUN apt-get update && apt-get install -y --no-install-recommends \         curl procps tini \
  • Dangerous shell operationline 272
    RUN apt-get update && apt-get install -y --no-install-recommends          curl procps tini      && rm -rf /var/lib/apt/lists/*
  • Network accessline 272
    RUN apt-get update && apt-get install -y --no-install-recommends          curl procps tini
  • Network accessline 273
    curl procps tini \
  • Dangerous shell operationline 274
    && rm -rf /var/lib/apt/lists/* \
  • Network accessline 274
    && rm -rf /var/lib/apt/lists/* \     && curl -fsSL "https://archive.apache.org/dist/spark/spark-${SPARK_VERSION}/spark-${SPARK_VERSION}-bin-hadoop${HADOOP_VERSION}.tgz" \        | tar -xz -C /opt/ \
  • Network accessline 275
    && curl -fsSL "https://archive.apache.org/dist/spark/spark-${SPARK_VERSION}/spark-${SPARK_VERSION}-bin-hadoop${HADOOP_VERSION}.tgz" \
  • Dangerous shell operationline 285
    RUN apt-get update && apt-get install -y --no-install-recommends python3 python3-pip      && rm -rf /var/lib/apt/lists/*
  • Dangerous shell operationline 286
    && rm -rf /var/lib/apt/lists/*

group_skills/infra_dataops_group_skills/infra_gitops_deployment_review/SKILL.md

  • Network accessline 70
    source:     repoURL: https://github.com/my-org/gitops-config
  • Network accessline 71
    repoURL: https://github.com/my-org/gitops-config
  • Network accessline 75
    destination:     server: https://kubernetes.default.svc
  • Network accessline 76
    server: https://kubernetes.default.svc
  • Network accessline 116
    project: data-platform   source:     repoURL: https://charts.bitnami.com/bitnami
  • Network accessline 117
    source:     repoURL: https://charts.bitnami.com/bitnami     chart: kafka
  • Network accessline 118
    repoURL: https://charts.bitnami.com/bitnami
  • Network accessline 129
    - values-prod.yaml      # from source repo at path   destination:     server: https://kubernetes.default.svc
  • Network accessline 130
    destination:     server: https://kubernetes.default.svc     namespace: kafka
  • Network accessline 131
    server: https://kubernetes.default.svc
  • Network accessline 147
    project: default   source:     repoURL: https://github.com/my-org/gitops-config
  • Network accessline 148
    source:     repoURL: https://github.com/my-org/gitops-config     targetRevision: main
  • Network accessline 149
    repoURL: https://github.com/my-org/gitops-config
  • Network accessline 151
    path: apps/production       # directory containing all Application YAMLs   destination:     server: https://kubernetes.default.svc
  • Network accessline 152
    destination:     server: https://kubernetes.default.svc     namespace: argocd
  • Network accessline 153
    server: https://kubernetes.default.svc
  • Network accessline 169
    project: data-platform   source:     repoURL: https://github.com/my-org/gitops-config
  • Network accessline 170
    source:     repoURL: https://github.com/my-org/gitops-config     targetRevision: main
  • Network accessline 171
    repoURL: https://github.com/my-org/gitops-config
  • Network accessline 175
    valueFiles: [values-prod.yaml]   destination:     server: https://kubernetes.default.svc
  • Network accessline 176
    destination:     server: https://kubernetes.default.svc     namespace: airflow
  • Network accessline 177
    server: https://kubernetes.default.svc
  • Network accessline 198
    sourceRepos:     - https://github.com/my-org/gitops-config
  • Network accessline 199
    - https://github.com/my-org/gitops-config
  • Network accessline 200
    - https://charts.bitnami.com/bitnami
  • Network accessline 201
    - https://helm.releases.hashicorp.com
  • Network accessline 203
    destinations:     - server: https://kubernetes.default.svc
  • Network accessline 204
    - server: https://kubernetes.default.svc
  • Network accessline 205
    namespace: airflow     - server: https://kubernetes.default.svc       namespace: kafka
  • Network accessline 206
    - server: https://kubernetes.default.svc
  • Network accessline 207
    namespace: kafka     - server: https://kubernetes.default.svc       namespace: spark
  • Network accessline 208
    - server: https://kubernetes.default.svc

group_skills/infra_dataops_group_skills/infra_grafana_dashboard_review/SKILL.md

  • Network accessline 186
    # Annotate Grafana with deployment events (via API) GRAFANA_URL="http://grafana.monitoring.svc:3000"
  • Network accessline 187
    GRAFANA_URL="http://grafana.monitoring.svc:3000"
  • Access to secretsline 188
    [Credential-related source omitted]
  • Network accessline 191
    local dag_id=$1   local version=$2   curl -s -X POST \
  • Network accessline 192
    local version=$2   curl -s -X POST \     -H "Content-Type: application/json" \
  • Network accessline 193
    [Credential-related source omitted]
  • Access to secretsline 193
    [Credential-related source omitted]
  • Access to secretsline 195
    [Credential-related source omitted]
  • Network accessline 211
    - name: Annotate Grafana   run: |     curl -s -X POST \
  • Network accessline 212
    [Credential-related source omitted]
  • Network accessline 213
    curl -s -X POST \
  • Network accessline 248
    annotations = {       summary = "Pipeline {{ $labels.dag_id }} data is stale"       runbook = "https://wiki.my-org.com/runbooks/pipeline-freshness"
  • Network accessline 249
    summary = "Pipeline {{ $labels.dag_id }} data is stale"       runbook = "https://wiki.my-org.com/runbooks/pipeline-freshness"     }
  • Network accessline 250
    runbook = "https://wiki.my-org.com/runbooks/pipeline-freshness"

group_skills/infra_dataops_group_skills/infra_kubernetes_cluster_health/SKILL.md

  • Network accessline 164
    # etcd health check (run inside etcd pod or host) ETCDCTL_API=3 etcdctl \   --endpoints=https://127.0.0.1:2379 \
  • Network accessline 165
    ETCDCTL_API=3 etcdctl    --endpoints=https://127.0.0.1:2379
  • Network accessline 166
    --endpoints=https://127.0.0.1:2379 \
  • Network accessline 172
    # Check etcd member list ETCDCTL_API=3 etcdctl member list \   --endpoints=https://127.0.0.1:2379 \
  • Network accessline 173
    ETCDCTL_API=3 etcdctl member list    --endpoints=https://127.0.0.1:2379
  • Network accessline 174
    --endpoints=https://127.0.0.1:2379 \

group_skills/infra_dataops_group_skills/infra_kubernetes_cost_optimizer/SKILL.md

  • Network accessline 63
    # Install Goldilocks helm repo add fairwinds-stable https://charts.fairwinds.com/stable
  • Network accessline 64
    helm repo add fairwinds-stable https://charts.fairwinds.com/stable

group_skills/infra_dataops_group_skills/infra_kubernetes_security_audit/SKILL.md

  • Network accessline 359
    # Run kube-bench (CIS Benchmark scan) kubectl apply -f https://raw.githubusercontent.com/aquasecurity/kube-bench/main/job.yaml
  • Network accessline 360
    kubectl apply -f https://raw.githubusercontent.com/aquasecurity/kube-bench/main/job.yaml

group_skills/infra_dataops_group_skills/infra_kubernetes_storage_review/SKILL.md

  • Network accessline 243
    # Install Longhorn helm repo add longhorn https://charts.longhorn.io
  • Network accessline 244
    helm repo add longhorn https://charts.longhorn.io

group_skills/infra_dataops_group_skills/infra_multi_cloud_governance/SKILL.md

  • Access to secretsline 77
    [Credential-related source omitted]
  • Access to secretsline 78
    [Credential-related source omitted]

group_skills/infra_dataops_group_skills/infra_network_security_review/SKILL.md

  • Access to secretsline 154
    [Credential-related source omitted]

group_skills/infra_dataops_group_skills/infra_observability_stack_review/SKILL.md

  • Network accessline 93
    exporters:   prometheusremotewrite:     endpoint: http://mimir:9090/api/v1/push
  • Network accessline 95
    endpoint: http://mimir:9090/api/v1/push
  • Network accessline 97
    loki:     endpoint: http://loki:3100/loki/api/v1/push
  • Network accessline 98
    endpoint: http://loki:3100/loki/api/v1/push
  • Network accessline 105
    otlp/tempo:     endpoint: http://tempo:4317
  • Network accessline 106
    endpoint: http://tempo:4317
  • Network accessline 131
    prometheus-community/kube-prometheus-stack \   -n monitoring \   --set prometheus.prometheusSpec.remoteWrite[0].url=http://mimir:9090/api/v1/push \
  • Network accessline 132
    -n monitoring \   --set prometheus.prometheusSpec.remoteWrite[0].url=http://mimir:9090/api/v1/push \   --set prometheus.prometheusSpec.retention=7d \
  • Network accessline 133
    --set prometheus.prometheusSpec.remoteWrite[0].url=http://mimir:9090/api/v1/push \   --set prometheus.prometheusSpec.retention=7d \   --set prometheus.prometheusSpec.storageSpec.volumeClaimTemplate.spec.resources.requests.storage=100Gi
  • Network accessline 141
    # Find high-cardinality metrics (> 10k series) curl -s http://prometheus:9090/api/v1/label/__name__/values \
  • Network accessline 142
    curl -s http://prometheus:9090/api/v1/label/__name__/values \
  • Network accessline 143
    | jq -r '.data[]' \   | while read metric; do       count=$(curl -sg "http://prometheus:9090/api/v1/query?query=count($metric)" \
  • Network accessline 144
    | while read metric; do       count=$(curl -sg "http://prometheus:9090/api/v1/query?query=count($metric)" \         | jq '.data.result[0].value[1]' 2>/dev/null)
  • Network accessline 145
    count=$(curl -sg "http://prometheus:9090/api/v1/query?query=count($metric)" \

group_skills/infra_dataops_group_skills/infra_opentelemetry_instrumentation/SKILL.md

  • Network accessline 31
    OTEL_SERVICE_NAME=etl-orders \ OTEL_RESOURCE_ATTRIBUTES="environment=production,team=data-engineering,version=1.2.0" \ OTEL_EXPORTER_OTLP_ENDPOINT=http://otel-collector:4317 \
  • Network accessline 32
    OTEL_RESOURCE_ATTRIBUTES="environment=production,team=data-engineering,version=1.2.0" \ OTEL_EXPORTER_OTLP_ENDPOINT=http://otel-collector:4317 \ OTEL_EXPORTER_OTLP_PROTOCOL=grpc \
  • Network accessline 33
    OTEL_EXPORTER_OTLP_ENDPOINT=http://otel-collector:4317 \
  • Network accessline 60
    provider = TracerProvider(resource=resource) provider.add_span_processor(     BatchSpanProcessor(OTLPSpanExporter(endpoint="http://otel-collector:4317"))
  • Network accessline 61
    provider.add_span_processor(     BatchSpanProcessor(OTLPSpanExporter(endpoint="http://otel-collector:4317")) )
  • Network accessline 62
    BatchSpanProcessor(OTLPSpanExporter(endpoint="http://otel-collector:4317"))

group_skills/infra_dataops_group_skills/infra_prometheus_optimization/SKILL.md

  • Network accessline 21
    # Check top metrics by series count (TSDB Status API) curl -s http://prometheus:9090/api/v1/status/tsdb | jq '
  • Network accessline 22
    curl -s http://prometheus:9090/api/v1/status/tsdb | jq '
  • Network accessline 25
    # Top label names by series count curl -s http://prometheus:9090/api/v1/status/tsdb | jq '
  • Network accessline 26
    curl -s http://prometheus:9090/api/v1/status/tsdb | jq '
  • Network accessline 29
    # Find a specific high-cardinality metric curl -s "http://prometheus:9090/api/v1/query?query=count({__name__='http_requests_total'})%20by%20(user_id)" \
  • Network accessline 30
    curl -s "http://prometheus:9090/api/v1/query?query=count({__name__='http_requests_total'})%20by%20(user_id)" \
  • Network accessline 33
    # Total active series curl -s "http://prometheus:9090/api/v1/query?query=prometheus_tsdb_head_series" \
  • Network accessline 34
    curl -s "http://prometheus:9090/api/v1/query?query=prometheus_tsdb_head_series" \
  • Network accessline 108
    global:   slack_api_url: ${SLACK_WEBHOOK_URL}   pagerduty_url: https://events.pagerduty.com/v2/enqueue
  • Network accessline 110
    pagerduty_url: https://events.pagerduty.com/v2/enqueue
  • Access to secretsline 150
    [Credential-related source omitted]
  • Network accessline 196
    # prometheus.yml remote_write:   - url: http://mimir.monitoring.svc:9090/api/v1/push
  • Network accessline 198
    - url: http://mimir.monitoring.svc:9090/api/v1/push

group_skills/infra_dataops_group_skills/infra_secrets_management_review/SKILL.md

  • Access to secretsline 107
    [Credential-related source omitted]
  • Network accessline 132
    provider:     vault:       server: http://vault.vault.svc.cluster.local:8200
  • Network accessline 133
    vault:       server: http://vault.vault.svc.cluster.local:8200       path: data-platform
  • Network accessline 134
    server: http://vault.vault.svc.cluster.local:8200
  • Network accessline 182
    "connections_path": "data-platform/data/airflow/connections",   "variables_path": "data-platform/data/airflow/variables",   "url": "http://vault.vault.svc.cluster.local:8200",
  • Network accessline 183
    "variables_path": "data-platform/data/airflow/variables",   "url": "http://vault.vault.svc.cluster.local:8200",   "auth_type": "kubernetes",
  • Network accessline 184
    "url": "http://vault.vault.svc.cluster.local:8200",
  • Network accessline 207
    # .pre-commit-config.yaml — detect secrets before commit repos:   - repo: https://github.com/gitleaks/gitleaks
  • Network accessline 208
    repos:   - repo: https://github.com/gitleaks/gitleaks     rev: v8.18.0
  • Network accessline 209
    - repo: https://github.com/gitleaks/gitleaks
  • Network accessline 214
    - repo: https://github.com/trufflesecurity/trufflehog
  • Dangerous shell operationline 267
    eval $(vault kv get -format=json data-platform/production/trino \

group_skills/infra_dataops_group_skills/infra_terraform_cost_estimator/SKILL.md

  • Network accessline 26
    # Linux curl -fsSL https://raw.githubusercontent.com/infracost/infracost/master/scripts/install.sh | sh
  • Dangerous shell operationline 27
    curl -fsSL https://raw.githubusercontent.com/infracost/infracost/master/scripts/install.sh | sh
  • Network accessline 27
    curl -fsSL https://raw.githubusercontent.com/infracost/infracost/master/scripts/install.sh | sh
  • Access to secretsline 122
    [Credential-related source omitted]

group_skills/infra_dataops_group_skills/infra_terraform_security_scan/SKILL.md

  • Network accessline 23
    # Install brew install tfsec              # macOS curl -s https://raw.githubusercontent.com/aquasecurity/tfsec/master/scripts/install_linux.sh | bash
  • Dangerous shell operationline 25
    curl -s https://raw.githubusercontent.com/aquasecurity/tfsec/master/scripts/install_linux.sh | bash
  • Network accessline 25
    curl -s https://raw.githubusercontent.com/aquasecurity/tfsec/master/scripts/install_linux.sh | bash
  • Access to secretsline 79
    [Credential-related source omitted]
  • Network accessline 311
    # .pre-commit-config.yaml repos:   - repo: https://github.com/antonbabenko/pre-commit-terraform
  • Network accessline 312
    repos:   - repo: https://github.com/antonbabenko/pre-commit-terraform     rev: v1.92.0
  • Network accessline 313
    - repo: https://github.com/antonbabenko/pre-commit-terraform
  • Network accessline 326
    - repo: https://github.com/gitleaks/gitleaks

group_skills/infra_dataops_group_skills/platform_engineering_data_platform_api/SKILL.md

  • Access to secretsline 69
    [Credential-related source omitted]
  • Access to secretsline 102
    [Credential-related source omitted]
  • Access to secretsline 106
    [Credential-related source omitted]

group_skills/infra_dataops_group_skills/platform_engineering_internal_developer_platform/SKILL.md

  • Network accessline 31
    backstage.io/techdocs-ref: dir:.     airflow.apache.org/dag-id: etl_orders     grafana.com/dashboard-url: https://grafana.internal/d/etl-orders
  • Network accessline 32
    airflow.apache.org/dag-id: etl_orders     grafana.com/dashboard-url: https://grafana.internal/d/etl-orders     runbook-url: https://wiki.internal/runbooks/etl-orders
  • Network accessline 33
    grafana.com/dashboard-url: https://grafana.internal/d/etl-orders
  • Network accessline 34
    runbook-url: https://wiki.internal/runbooks/etl-orders
  • Network accessline 39
    - gold-layer   links:     - url: https://airflow.internal/dags/etl_orders
  • Network accessline 40
    links:     - url: https://airflow.internal/dags/etl_orders       title: Airflow DAG
  • Network accessline 41
    - url: https://airflow.internal/dags/etl_orders
  • Network accessline 83
    description: "Raw orders events from order service — Avro schema"   annotations:     schema-registry-url: https://schema-registry.internal/subjects/orders-raw-value
  • Network accessline 84
    annotations:     schema-registry-url: https://schema-registry.internal/subjects/orders-raw-value spec:
  • Network accessline 85
    schema-registry-url: https://schema-registry.internal/subjects/orders-raw-value

group_skills/starrocks_group_skills/airflow_starrocks_cdc_orchestrator/SKILL.md

  • Network accessline 120
    resp = requests.put(
  • Network accessline 121
    f"http://sr-fe.internal:8030/api/{DATABASE}/{table}/_stream_load",
  • Network accessline 375
    resp = requests.put(
  • Network accessline 376
    f"http://sr-fe.internal:8030/api/sales/{params['target_table']}/_stream_load",
  • Network accessline 442
    """Signal Debezium to refresh schema via Kafka Connect REST API."""         import requests         resp = requests.post(
  • Network accessline 443
    import requests         resp = requests.post(             "http://kafka-connect:8083/connectors/postgres-cdc-source/tasks/0/restart"
  • Network accessline 444
    resp = requests.post(
  • Network accessline 445
    "http://kafka-connect:8083/connectors/postgres-cdc-source/tasks/0/restart"

group_skills/starrocks_group_skills/airflow_starrocks_pipeline/SKILL.md

  • Network accessline 249
    resp = requests.put(
  • Network accessline 250
    "http://sr-fe.internal:8030/api/sales/events/_stream_load",

group_skills/starrocks_group_skills/dbt_starrocks_production_readiness/SKILL.md

  • Access to secretsline 79
    [Credential-related source omitted]

group_skills/starrocks_group_skills/dbt_starrocks_semantic_layer/SKILL.md

  • Network accessline 309
    type: dashboard     maturity: production     url: "https://grafana.internal/d/revenue-main"
  • Network accessline 310
    maturity: production     url: "https://grafana.internal/d/revenue-main"     owner:
  • Network accessline 311
    url: "https://grafana.internal/d/revenue-main"

group_skills/starrocks_group_skills/starrocks_admin_backup_restore/SKILL.md

  • Network accessline 87
    "aws.s3.access_key"        = "minioadmin",     "aws.s3.secret_key"        = "minioadmin",     "aws.s3.endpoint"          = "http://minio.internal:9000",
  • Network accessline 88
    "aws.s3.secret_key"        = "minioadmin",     "aws.s3.endpoint"          = "http://minio.internal:9000",     "aws.s3.region"            = "us-east-1",
  • Network accessline 89
    "aws.s3.endpoint"          = "http://minio.internal:9000",
  • Network accessline 834
    - [StarRocks Backup and Restore — Official Guide](https://docs.starrocks.io/docs/administration/management/backup_recovery/backup_and_restore/)
  • Network accessline 835
    - [BACKUP SQL Reference](https://docs.starrocks.io/docs/sql-reference/sql-statements/backup_restore/BACKUP/)
  • Network accessline 836
    - [RESTORE SQL Reference](https://docs.starrocks.io/docs/sql-reference/sql-statements/backup_restore/RESTORE/)
  • Network accessline 837
    - [CREATE REPOSITORY SQL Reference](https://docs.starrocks.io/docs/sql-reference/sql-statements/backup_restore/CREATE_REPOSITORY/)
  • Network accessline 838
    - [SHOW BACKUP SQL Reference](https://docs.starrocks.io/docs/sql-reference/sql-statements/backup_restore/SHOW_BACKUP/)
  • Network accessline 839
    - [SHOW RESTORE SQL Reference](https://docs.starrocks.io/docs/sql-reference/sql-statements/backup_restore/SHOW_RESTORE/)
  • Network accessline 840
    - [SHOW SNAPSHOT SQL Reference](https://docs.starrocks.io/docs/sql-reference/sql-statements/backup_restore/SHOW_SNAPSHOT/)
  • Network accessline 841
    - [StarRocks Broker Configuration](https://docs.starrocks.io/docs/deployment/deploy_broker/)
  • Network accessline 842
    - [S3 Lifecycle Rules — AWS Documentation](https://docs.aws.amazon.com/AmazonS3/latest/userguide/object-lifecycle-mgmt.html)

group_skills/starrocks_group_skills/starrocks_admin_cluster_health/SKILL.md

  • Network accessline 362
    # View current compaction config on a BE curl http://be_host:8040/api/show_config | grep -i compaction
  • Network accessline 363
    curl http://be_host:8040/api/show_config | grep -i compaction
  • Network accessline 365
    # Increase parallelism for cumulative compaction (BE config, requires restart or dynamic set) curl -X POST http://be_host:8040/api/update_config \
  • Network accessline 366
    curl -X POST http://be_host:8040/api/update_config \
  • Network accessline 369
    curl -X POST http://be_host:8040/api/update_config \
  • Network accessline 372
    # Lower the score threshold that triggers base compaction curl -X POST http://be_host:8040/api/update_config \
  • Network accessline 373
    curl -X POST http://be_host:8040/api/update_config \
  • Network accessline 984
    - StarRocks docs — Cluster Management: `https://docs.starrocks.io/docs/administration/management/cluster_management/`
  • Network accessline 985
    - StarRocks docs — Monitoring Metrics: `https://docs.starrocks.io/docs/administration/management/monitoring/metrics/`
  • Network accessline 986
    - StarRocks docs — System Variables: `https://docs.starrocks.io/docs/reference/System_variable/`
  • Network accessline 987
    - StarRocks docs — `information_schema` tables: `https://docs.starrocks.io/docs/reference/information_schema/`
  • Network accessline 988
    - StarRocks docs — ADMIN commands reference: `https://docs.starrocks.io/docs/sql-reference/sql-statements/Administration/`
  • Network accessline 989
    - StarRocks docs — Tablet Scheduler internals: `https://docs.starrocks.io/docs/administration/management/tablet_management/`

group_skills/starrocks_group_skills/starrocks_admin_compaction/SKILL.md

  • Network accessline 206
    # Get compaction score for all tablets on BE (port 8040 is BE HTTP port) curl -s http://<be_host>:8040/api/compaction/show?tablet_id=<tablet_id>
  • Network accessline 207
    curl -s http://<be_host>:8040/api/compaction/show?tablet_id=<tablet_id>
  • Network accessline 423
    # BE HTTP API: inspect a specific PKT tablet's delete vector stats curl -s "http://<be_host>:8040/api/update/get_del_vec?tablet_id=<tablet_id>"
  • Network accessline 424
    curl -s "http://<be_host>:8040/api/update/get_del_vec?tablet_id=<tablet_id>"
  • Network accessline 467
    # Trigger cumulative compaction on a specific tablet curl -X POST "http://<be_host>:8040/api/compaction/run?tablet_id=<tablet_id>&compact_type=cumulative"
  • Network accessline 468
    curl -X POST "http://<be_host>:8040/api/compaction/run?tablet_id=<tablet_id>&compact_type=cumulative"
  • Network accessline 470
    # Trigger base compaction on a specific tablet curl -X POST "http://<be_host>:8040/api/compaction/run?tablet_id=<tablet_id>&compact_type=base"
  • Network accessline 471
    curl -X POST "http://<be_host>:8040/api/compaction/run?tablet_id=<tablet_id>&compact_type=base"
  • Network accessline 475
    # Check tablet compaction status curl -s "http://<be_host>:8040/api/compaction/show?tablet_id=<tablet_id>"
  • Network accessline 476
    curl -s "http://<be_host>:8040/api/compaction/show?tablet_id=<tablet_id>"
  • Network accessline 511
    # BAD: many small loads for file in /data/day/*.csv; do     curl -X PUT "http://<fe_host>:8030/api/mydb/mytable/_stream_load" \
  • Network accessline 512
    for file in /data/day/*.csv; do     curl -X PUT "http://<fe_host>:8030/api/mydb/mytable/_stream_load" \         -H "label: load_$(date +%s%N)" \
  • Network accessline 513
    curl -X PUT "http://<fe_host>:8030/api/mydb/mytable/_stream_load" \
  • Network accessline 518
    # GOOD: concatenate or use larger batches cat /data/day/*.csv | curl -X PUT "http://<fe_host>:8030/api/mydb/mytable/_stream_load" \
  • Network accessline 519
    cat /data/day/*.csv | curl -X PUT "http://<fe_host>:8030/api/mydb/mytable/_stream_load" \
  • Network accessline 540
    df.write \     .format("starrocks") \     .option("starrocks.fe.http.url", "http://fe_host:8030") \
  • Network accessline 541
    .format("starrocks") \     .option("starrocks.fe.http.url", "http://fe_host:8030") \     .option("starrocks.write.properties.buffer_size", "268435456") \
  • Network accessline 542
    .option("starrocks.fe.http.url", "http://fe_host:8030") \
  • Network accessline 705
    # 2. Verify compaction threads are not all blocked curl -s "http://<be_host>:8040/api/compaction/show" | python3 -m json.tool
  • Dangerous shell operationline 706
    curl -s "http://<be_host>:8040/api/compaction/show" | python3 -m json.tool
  • Network accessline 706
    curl -s "http://<be_host>:8040/api/compaction/show" | python3 -m json.tool
  • Network accessline 760
    # Disable cumulative compaction on a specific BE via HTTP API curl -X POST "http://<be_host>:8040/api/update_config?cumulative_compaction_check_interval_seconds=3600"
  • Network accessline 761
    curl -X POST "http://<be_host>:8040/api/update_config?cumulative_compaction_check_interval_seconds=3600"
  • Network accessline 763
    # Re-enable curl -X POST "http://<be_host>:8040/api/update_config?cumulative_compaction_check_interval_seconds=1"
  • Network accessline 764
    curl -X POST "http://<be_host>:8040/api/update_config?cumulative_compaction_check_interval_seconds=1"
  • Network accessline 803
    # Step 3: For top offender tablet, check score curl -s "http://<be_host>:8040/api/compaction/show?tablet_id=<tablet_id>"
  • Network accessline 804
    curl -s "http://<be_host>:8040/api/compaction/show?tablet_id=<tablet_id>"
  • Network accessline 806
    # Step 4: Manually trigger if needed curl -X POST "http://<be_host>:8040/api/compaction/run?tablet_id=<tablet_id>&compact_type=cumulative"
  • Network accessline 807
    curl -X POST "http://<be_host>:8040/api/compaction/run?tablet_id=<tablet_id>&compact_type=cumulative"
  • Network accessline 809
    # Step 5: Verify progress curl -s "http://<be_host>:8040/api/compaction/show?tablet_id=<tablet_id>"
  • Network accessline 810
    curl -s "http://<be_host>:8040/api/compaction/show?tablet_id=<tablet_id>"
  • Network accessline 833
    - [StarRocks Compaction Overview](https://docs.starrocks.io/docs/administration/management/compaction/)
  • Network accessline 834
    - [StarRocks BE Configuration Reference](https://docs.starrocks.io/docs/administration/Configuration/)
  • Network accessline 835
    - [StarRocks Primary Key Table](https://docs.starrocks.io/docs/table_design/table_types/primary_key_table/)
  • Network accessline 836
    - [StarRocks SHOW PROC](https://docs.starrocks.io/docs/administration/management/monitoring/Monitor_and_Alert/)
  • Network accessline 837
    - [StarRocks information_schema](https://docs.starrocks.io/docs/reference/information_schema/be_compactions/)
  • Network accessline 838
    - [StarRocks ALTER TABLE COMPACT](https://docs.starrocks.io/docs/sql-reference/sql-statements/data-definition/ALTER_TABLE/)
  • Network accessline 839
    - [StarRocks Tablet Management](https://docs.starrocks.io/docs/administration/management/tablet_index/)

group_skills/starrocks_group_skills/starrocks_admin_query_monitor/SKILL.md

  • Network accessline 750
    - StarRocks docs — Resource Groups: `https://docs.starrocks.io/docs/administration/management/resource_management/resource_group/`
  • Network accessline 751
    - StarRocks docs — Query Management: `https://docs.starrocks.io/docs/administration/Query_management/Query_management/`
  • Network accessline 752
    - StarRocks docs — information_schema reference: `https://docs.starrocks.io/docs/reference/information_schema/`
  • Network accessline 753
    - StarRocks docs — Audit Loader plugin: `https://docs.starrocks.io/docs/administration/audit_loader/`
  • Network accessline 754
    - StarRocks docs — Memory spill: `https://docs.starrocks.io/docs/administration/management/resource_management/spill_to_disk/`

group_skills/starrocks_group_skills/starrocks_admin_security/SKILL.md

  • Network accessline 738
    - [StarRocks Privilege Overview](https://docs.starrocks.io/docs/administration/user_privs/privilege_overview/)
  • Network accessline 739
    - [StarRocks RBAC Guide](https://docs.starrocks.io/docs/administration/user_privs/role_based_access_control/)
  • Network accessline 740
    - [User Privileges Overview](https://docs.starrocks.io/docs/administration/user_privs/)
  • Network accessline 741
    - [StarRocks CREATE USER syntax](https://docs.starrocks.io/docs/sql-reference/sql-statements/account-management/CREATE_USER/)
  • Network accessline 742
    - [StarRocks GRANT syntax](https://docs.starrocks.io/docs/sql-reference/sql-statements/account-management/GRANT/)
  • Network accessline 743
    - [StarRocks Row Access Policy](https://docs.starrocks.io/docs/administration/user_privs/row_policy/)
  • Network accessline 744
    - [StarRocks Data Masking](https://docs.starrocks.io/docs/administration/user_privs/column_masking/)
  • Network accessline 745
    - [StarRocks Audit Log](https://docs.starrocks.io/docs/administration/audit_loader/)
  • Network accessline 746
    - [StarRocks SSL/TLS Config](https://docs.starrocks.io/docs/administration/ssl/)

group_skills/starrocks_group_skills/starrocks_admin_storage_balancer/SKILL.md

  • Network accessline 501
    Scrape BE metrics from `http://be_host:8040/metrics`:
  • Network accessline 701
    curl -X POST http://be_host:8040/api/update_config \
  • Network accessline 756
    - StarRocks docs — Tablet scheduler internals: `https://docs.starrocks.io/docs/administration/management/tablet_management/`
  • Network accessline 757
    - StarRocks docs — Scale up/down (add/remove BE): `https://docs.starrocks.io/docs/administration/management/Scale_up_down/`
  • Network accessline 758
    - StarRocks docs — FE configuration reference: `https://docs.starrocks.io/docs/administration/management/FE_configuration/`
  • Network accessline 759
    - StarRocks docs — BE configuration reference: `https://docs.starrocks.io/docs/administration/management/BE_configuration/`
  • Network accessline 760
    - StarRocks docs — Monitoring metrics (Prometheus): `https://docs.starrocks.io/docs/administration/management/monitoring/metrics/`
  • Network accessline 761
    - StarRocks docs — ADMIN commands reference: `https://docs.starrocks.io/docs/sql-reference/sql-statements/Administration/`
  • Network accessline 762
    - StarRocks docs — `information_schema` tables: `https://docs.starrocks.io/docs/reference/information_schema/`
  • Network accessline 763
    - StarRocks docs — Cluster management overview: `https://docs.starrocks.io/docs/administration/management/cluster_management/`

group_skills/starrocks_group_skills/starrocks_ai_incident_rca/SKILL.md

  • Network accessline 200
    actions = {         "error_threshold_exceeded": (             "Check ErrorLogUrls: curl 'http://be:8040/api/_load_error_log?file=...' | head -50\n"
  • Network accessline 201
    "error_threshold_exceeded": (             "Check ErrorLogUrls: curl 'http://be:8040/api/_load_error_log?file=...' | head -50\n"             "Fix source data or increase max_error_number\n"
  • Network accessline 202
    "Check ErrorLogUrls: curl 'http://be:8040/api/_load_error_log?file=...' | head -50\n"

group_skills/starrocks_group_skills/starrocks_broker_load/SKILL.md

  • Access to secretsline 48
    [Credential-related source omitted]
  • Access to secretsline 49
    [Credential-related source omitted]
  • Network accessline 77
    "aws.s3.access_key" = "minio_user",     "aws.s3.secret_key" = "minio_password",     "aws.s3.endpoint" = "http://minio.internal:9000",
  • Network accessline 78
    "aws.s3.secret_key" = "minio_password",     "aws.s3.endpoint" = "http://minio.internal:9000",     "aws.s3.enable_path_style_access" = "true"  -- required for MinIO
  • Network accessline 79
    "aws.s3.endpoint" = "http://minio.internal:9000",

group_skills/starrocks_group_skills/starrocks_bucketing/SKILL.md

  • Network accessline 787
    - [StarRocks Data Distribution Documentation](https://docs.starrocks.io/docs/table_design/data_distribution/)
  • Network accessline 788
    - [StarRocks Colocate Join Documentation](https://docs.starrocks.io/docs/table_design/data_distribution/colocate_join/)
  • Network accessline 789
    - [StarRocks Table Design Overview](https://docs.starrocks.io/docs/table_design/StarRocks_table_design/)
  • Network accessline 790
    - [StarRocks ALTER TABLE Syntax](https://docs.starrocks.io/docs/sql-reference/sql-statements/table_bucket_part_index/ALTER_TABLE/)
  • Network accessline 791
    - [StarRocks information_schema Reference](https://docs.starrocks.io/docs/reference/information_schema/be_tablets/)

group_skills/starrocks_group_skills/starrocks_concurrency_optimizer/SKILL.md

  • Network accessline 278
    -- Query queue statistics via FE metrics endpoint -- GET http://fe-host:8030/metrics  (look for query_queue_*)
  • Network accessline 279
    -- GET http://fe-host:8030/metrics  (look for query_queue_*)
  • Network accessline 750
    -- 3. Query latency histogram (BE metrics endpoint) -- GET http://be-host:8040/metrics  → search for query_execution_time_us_*
  • Network accessline 751
    -- GET http://be-host:8040/metrics  → search for query_execution_time_us_*
  • Network accessline 872
    - StarRocks 3.x Documentation: [Resource Groups](https://docs.starrocks.io/docs/administration/resource_group/)
  • Network accessline 873
    - StarRocks 3.x Documentation: [Query Queue](https://docs.starrocks.io/docs/administration/query_queues/)
  • Network accessline 874
    - StarRocks 3.x Documentation: [Query Cache](https://docs.starrocks.io/docs/using_starrocks/query_cache/)
  • Network accessline 875
    - StarRocks 3.x Documentation: [Pipeline Engine](https://docs.starrocks.io/docs/administration/BE_configuration/)
  • Network accessline 876
    - StarRocks 3.x Documentation: [Primary Key Table](https://docs.starrocks.io/docs/table_design/table_types/primary_key_table/)
  • Network accessline 877
    - StarRocks 3.x Documentation: [FE Configuration](https://docs.starrocks.io/docs/administration/FE_configuration/)

group_skills/starrocks_group_skills/starrocks_data_modeling/SKILL.md

  • Network accessline 956
    - StarRocks Table Design overview: https://docs.starrocks.io/docs/table_design/
  • Network accessline 957
    - StarRocks Table Types: https://docs.starrocks.io/docs/table_design/table_types/
  • Network accessline 958
    - StarRocks Sort Key and Prefix Index: https://docs.starrocks.io/docs/table_design/sort_key/
  • Network accessline 959
    - StarRocks Distribution: https://docs.starrocks.io/docs/table_design/data_distribution/
  • Network accessline 960
    - StarRocks Bitmap Index: https://docs.starrocks.io/docs/table_design/indexes/Bitmap_index/
  • Network accessline 961
    - StarRocks Bloom Filter Index: https://docs.starrocks.io/docs/table_design/indexes/Bloomfilter_index/
  • Network accessline 962
    - StarRocks Materialized Views: https://docs.starrocks.io/docs/using_starrocks/async_mv/
  • Network accessline 963
    - StarRocks Best Practices: https://docs.starrocks.io/docs/best_practices/
  • Network accessline 964
    - StarRocks Primary Key table (partial update, DELETE): https://docs.starrocks.io/docs/table_design/table_types/primary_key_table/

group_skills/starrocks_group_skills/starrocks_ddl_table_types/SKILL.md

  • Network accessline 997
    - StarRocks documentation: Table types overview — `https://docs.starrocks.io/docs/table_design/table_types/`
  • Network accessline 998
    - Duplicate Key table — `https://docs.starrocks.io/docs/table_design/table_types/duplicate_key_table/`
  • Network accessline 999
    - Aggregate Key table — `https://docs.starrocks.io/docs/table_design/table_types/aggregate_table/`
  • Network accessline 1000
    - Unique Key table — `https://docs.starrocks.io/docs/table_design/table_types/unique_key_table/`
  • Network accessline 1001
    - Primary Key table — `https://docs.starrocks.io/docs/table_design/table_types/primary_key_table/`
  • Network accessline 1002
    - Sort key and prefix index — `https://docs.starrocks.io/docs/table_design/indexes/Prefix_index_sort_key/`
  • Network accessline 1003
    - Data distribution — `https://docs.starrocks.io/docs/table_design/Data_distribution/`
  • Network accessline 1004
    - CREATE TABLE DDL reference — `https://docs.starrocks.io/docs/sql-reference/sql-statements/table_bucket_part_index/CREATE_TABLE/`
  • Network accessline 1005
    - ALTER TABLE reference — `https://docs.starrocks.io/docs/sql-reference/sql-statements/table_bucket_part_index/ALTER_TABLE/`

group_skills/starrocks_group_skills/starrocks_explain_plan/SKILL.md

  • Network accessline 799
    - StarRocks 3.x documentation: Query Profile and EXPLAIN — [docs.starrocks.io](https://docs.starrocks.io/docs/administration/query_profile_overview/)
  • Network accessline 800
    - StarRocks 3.x EXPLAIN ANALYZE syntax — [docs.starrocks.io](https://docs.starrocks.io/docs/sql-reference/sql-statements/cluster-management/plan_profile/EXPLAIN_ANALYZE/)
  • Network accessline 801
    - Query optimizer hints (`JOIN_HINT`, `USE_MV`) — [docs.starrocks.io](https://docs.starrocks.io/docs/sql-reference/sql-hints/)
  • Network accessline 802
    - Runtime filter configuration — [docs.starrocks.io](https://docs.starrocks.io/docs/using_starrocks/runtime_filter/)
  • Network accessline 803
    - `ANALYZE TABLE` statistics collection — [docs.starrocks.io](https://docs.starrocks.io/docs/using_starrocks/Cost_based_optimizer/)

group_skills/starrocks_group_skills/starrocks_files_ingestion/SKILL.md

  • Network accessline 128
    "type" = "iceberg",     "iceberg.catalog.type" = "rest",     "iceberg.catalog.uri" = "https://polaris.internal/api/catalog",
  • Network accessline 129
    "iceberg.catalog.type" = "rest",     "iceberg.catalog.uri" = "https://polaris.internal/api/catalog",     "iceberg.catalog.warehouse" = "my_warehouse",
  • Network accessline 130
    "iceberg.catalog.uri" = "https://polaris.internal/api/catalog",
  • Access to secretsline 134
    [Credential-related source omitted]
  • Network accessline 150
    "aws.s3.access_key" = "minio_user",     "aws.s3.secret_key" = "minio_password",     "aws.s3.endpoint" = "http://minio.internal:9000",
  • Network accessline 151
    "aws.s3.secret_key" = "minio_password",     "aws.s3.endpoint" = "http://minio.internal:9000",     "aws.s3.enable_path_style_access" = "true"
  • Network accessline 152
    "aws.s3.endpoint" = "http://minio.internal:9000",

group_skills/starrocks_group_skills/starrocks_join_optimization/SKILL.md

  • Network accessline 820
    - StarRocks documentation: [Join Optimization](https://docs.starrocks.io/docs/using_starrocks/query_acceleration/join_optimization/)
  • Network accessline 821
    - StarRocks documentation: [Colocate Join](https://docs.starrocks.io/docs/using_starrocks/colocate_join/)
  • Network accessline 822
    - StarRocks documentation: [Runtime Filter](https://docs.starrocks.io/docs/using_starrocks/query_acceleration/runtime_filter/)
  • Network accessline 823
    - StarRocks documentation: [CBO Optimizer](https://docs.starrocks.io/docs/using_starrocks/Cost_based_optimizer/)
  • Network accessline 824
    - StarRocks documentation: [Query Hints](https://docs.starrocks.io/docs/sql-reference/sql-statements/query_hints/)

group_skills/starrocks_group_skills/starrocks_lakehouse_integration/SKILL.md

  • Network accessline 67
    "type" = "iceberg",     "iceberg.catalog.type" = "rest",     "iceberg.catalog.uri" = "https://polaris.internal/api/catalog",
  • Network accessline 68
    "iceberg.catalog.type" = "rest",     "iceberg.catalog.uri" = "https://polaris.internal/api/catalog",     "iceberg.catalog.warehouse" = "production_warehouse",
  • Network accessline 69
    "iceberg.catalog.uri" = "https://polaris.internal/api/catalog",
  • Access to secretsline 72
    [Credential-related source omitted]
  • Network accessline 87
    "aws.s3.access_key" = "minio_user",     "aws.s3.secret_key" = "minio_password",     "aws.s3.endpoint" = "http://minio.internal:9000",
  • Network accessline 88
    "aws.s3.secret_key" = "minio_password",     "aws.s3.endpoint" = "http://minio.internal:9000",     "aws.s3.enable_path_style_access" = "true"
  • Network accessline 89
    "aws.s3.endpoint" = "http://minio.internal:9000",

group_skills/starrocks_group_skills/starrocks_materialized_views/SKILL.md

  • Network accessline 1150
    - StarRocks 3.x Documentation — Materialized Views Overview: `https://docs.starrocks.io/docs/using_starrocks/Materialized_view/`
  • Network accessline 1151
    - StarRocks 3.x Documentation — Synchronous Materialized Views: `https://docs.starrocks.io/docs/using_starrocks/Materialized_view-single_table/`
  • Network accessline 1152
    - StarRocks 3.x Documentation — Asynchronous Materialized Views: `https://docs.starrocks.io/docs/using_starrocks/async_mv/Materialized_view/`
  • Network accessline 1153
    - StarRocks 3.x Documentation — Query Rewrite with MVs: `https://docs.starrocks.io/docs/using_starrocks/query_rewrite_with_materialized_views/`
  • Network accessline 1154
    - StarRocks 3.x Documentation — CREATE MATERIALIZED VIEW (DDL reference): `https://docs.starrocks.io/docs/sql-reference/sql-statements/data-definition/CREATE_MATERIALIZED_VIEW/`
  • Network accessline 1155
    - StarRocks 3.x Documentation — External Catalogs (Iceberg, Hive): `https://docs.starrocks.io/docs/data_source/catalog/iceberg_catalog/`

group_skills/starrocks_group_skills/starrocks_memory_tuning/SKILL.md

  • Network accessline 414
    # Full mem_tracker tree (all trackers, hierarchical) curl -s http://<be_host>:8040/api/mem_tracker | python3 -m json.tool
  • Dangerous shell operationline 415
    curl -s http://<be_host>:8040/api/mem_tracker | python3 -m json.tool
  • Network accessline 415
    curl -s http://<be_host>:8040/api/mem_tracker | python3 -m json.tool
  • Network accessline 417
    # Filter for top memory consumers curl -s http://<be_host>:8040/api/mem_tracker \
  • Dangerous shell operationline 418
    curl -s http://<be_host>:8040/api/mem_tracker    | python3 -c "
  • Network accessline 418
    curl -s http://<be_host>:8040/api/mem_tracker \
  • Network accessline 651
    # Dump jemalloc stats via BE HTTP API (requires MALLOC_CONF=stats_print:true or explicit call) curl -s http://<be_host>:8040/api/jeprof/heap > heap.prof
  • Network accessline 652
    curl -s http://<be_host>:8040/api/jeprof/heap > heap.prof
  • Network accessline 654
    # Check retained memory vs allocated curl -s http://<be_host>:8040/api/mem_tracker \
  • Dangerous shell operationline 655
    curl -s http://<be_host>:8040/api/mem_tracker    | python3 -c "import json,sys; d=json.load(sys.stdin); print(json.dumps(d.get('jemalloc',{}), indent=2))"
  • Network accessline 655
    curl -s http://<be_host>:8040/api/mem_tracker \
  • Network accessline 962
    - StarRocks 3.x documentation: Memory Management — `https://docs.starrocks.io/docs/administration/management/resource_management/Memory_management/`
  • Network accessline 963
    - StarRocks 3.x documentation: Resource Groups — `https://docs.starrocks.io/docs/administration/management/resource_management/resource_group/`
  • Network accessline 964
    - StarRocks 3.x documentation: Query Spill — `https://docs.starrocks.io/docs/administration/management/resource_management/spill_to_disk/`
  • Network accessline 965
    - StarRocks 3.x documentation: Primary Key table — `https://docs.starrocks.io/docs/table_design/table_types/primary_key_table/`

group_skills/starrocks_group_skills/starrocks_query_optimizer/SKILL.md

  • Network accessline 616
    Access via `curl http://<be_host>:8040/metrics | grep query_cache`.

group_skills/starrocks_group_skills/starrocks_realtime_modeling/SKILL.md

  • Network accessline 314
    -- Step 3: Access FE error log URLs returned in ErrorLogUrls -- These are HTTP endpoints served by FE; download with curl: --   curl http://<fe_host>:8030/api/_load_error_log?file=<error_log_path>
  • Network accessline 316
    --   curl http://<fe_host>:8030/api/_load_error_log?file=<error_log_path>
  • Network accessline 937
    - StarRocks documentation: Primary Key table — https://docs.starrocks.io/docs/table_design/table_types/primary_key_table/
  • Network accessline 938
    - StarRocks documentation: Routine Load — https://docs.starrocks.io/docs/loading/RoutineLoad/
  • Network accessline 939
    - StarRocks documentation: Flink connector — https://docs.starrocks.io/docs/loading/Flink-connector-starrocks/
  • Network accessline 940
    - StarRocks documentation: Asynchronous materialized views — https://docs.starrocks.io/docs/using_starrocks/Materialized_view/
  • Network accessline 941
    - StarRocks documentation: Partial update — https://docs.starrocks.io/docs/loading/partial_update/
  • Network accessline 942
    - Flink CDC connectors — https://nightlies.apache.org/flink/flink-cdc-docs-stable/

group_skills/starrocks_group_skills/starrocks_routine_load_kafka/SKILL.md

  • Network accessline 154
    "kafka_broker_list" = "kafka:9092",     "kafka_topic" = "orders_avro",     "confluent.schema.registry.url" = "http://schema-registry:8081",
  • Network accessline 155
    "kafka_topic" = "orders_avro",     "confluent.schema.registry.url" = "http://schema-registry:8081",     "property.group.id" = "sr_avro_consumer"
  • Network accessline 156
    "confluent.schema.registry.url" = "http://schema-registry:8081",
  • Network accessline 326
    curl "http://be-host:8040/api/_load_error_log?file=error_log_xxx" | head -100

group_skills/starrocks_group_skills/starrocks_schema_evolution/SKILL.md

  • Network accessline 647
    - StarRocks 3.x Documentation: `ALTER TABLE` — https://docs.starrocks.io/docs/sql-reference/sql-statements/data-definition/ALTER_TABLE/
  • Network accessline 648
    - StarRocks 3.x Documentation: Schema Change Overview — https://docs.starrocks.io/docs/table_design/schema_change/
  • Network accessline 649
    - StarRocks 3.x Documentation: Primary Key table DML — https://docs.starrocks.io/docs/table_design/table_types/primary_key_table/
  • Network accessline 650
    - dbt StarRocks adapter: https://github.com/StarRocks/starrocks/tree/main/contrib/starrocks-connector-for-dbt

group_skills/starrocks_group_skills/starrocks_stream_load/SKILL.md

  • Network accessline 37
    # Load CSV from file curl --location-trusted \
  • Network accessline 38
    curl --location-trusted \
  • Network accessline 44
    -T /data/orders_20240115.csv \   -XPUT \   "http://fe-host:8030/api/sales/orders/_stream_load"
  • Network accessline 46
    "http://fe-host:8030/api/sales/orders/_stream_load"
  • Network accessline 52
    # Tab-separated curl ... -H "column_separator:\t" ...
  • Network accessline 53
    curl ... -H "column_separator:\t" ...
  • Network accessline 55
    # Multi-char separator (up to 50 bytes) curl ... -H "column_separator:|" ...
  • Network accessline 56
    curl ... -H "column_separator:|" ...
  • Network accessline 58
    # Null value representation curl ... -H "null_values_indicator:\N" ...
  • Network accessline 59
    curl ... -H "null_values_indicator:\N" ...
  • Network accessline 69
    curl --location-trusted \
  • Network accessline 76
    -T /data/orders.ndjson \   -XPUT \   "http://fe-host:8030/api/sales/orders/_stream_load"
  • Network accessline 78
    "http://fe-host:8030/api/sales/orders/_stream_load"
  • Network accessline 84
    # Input: [{"id":1,"val":"a"},{"id":2,"val":"b"}] curl ... \
  • Network accessline 85
    curl ... \
  • Network accessline 95
    # Map JSON fields to table columns with expressions curl ... \
  • Network accessline 96
    curl ... \
  • Network accessline 132
    # Only update `status` and `updated_at` columns curl --location-trusted \
  • Network accessline 133
    curl --location-trusted \
  • Network accessline 141
    -d '{"order_id":12345,"status":"shipped","updated_at":"2024-01-15 10:30:00"}' \   -XPUT \   "http://fe-host:8030/api/sales/orders/_stream_load"
  • Network accessline 143
    "http://fe-host:8030/api/sales/orders/_stream_load"
  • Network accessline 177
    "Status": "Success",     "NumberFilteredRows": 50,     "ErrorURL": "http://be-host:8040/api/_load_error_log?file=error_log_xxx"
  • Network accessline 178
    "NumberFilteredRows": 50,     "ErrorURL": "http://be-host:8040/api/_load_error_log?file=error_log_xxx" }
  • Network accessline 179
    "ErrorURL": "http://be-host:8040/api/_load_error_log?file=error_log_xxx"
  • Network accessline 185
    curl "http://be-host:8040/api/_load_error_log?file=error_log_xxx" | head -50
  • Network accessline 209
    [Credential-related source omitted]
  • Network accessline 210
    [Credential-related source omitted]
  • Network accessline 211
    self.base_url = f"http://{host}:{port}/api/{database}"
  • Network accessline 243
    url = f"{self.base_url}/{table}/_stream_load"         resp = requests.put(
  • Network accessline 244
    resp = requests.put(
  • Network accessline 281
    url = f"{self.base_url}/{table}/_stream_load"         resp = requests.put(
  • Network accessline 282
    resp = requests.put(
  • Network accessline 342
    curl ... \
  • Network accessline 401
    5. **Not checking ErrorURL** — `NumberFilteredRows > 0` means data loss; always fetch error log. 6. **Sending requests to BE directly** — send to FE for proper load routing and monitoring; BE direct is only for internal optimization. 7. **N
  • Network accessline 403
    7. **No Expect:100-continue** — without it, curl sends all data before getting auth failure; wastes bandwidth.

group_skills/trino_group_skills/trino_admin_cluster_health/SKILL.md

  • Network accessline 23
    COORDINATOR="http://trino-coordinator:8080"
  • Network accessline 25
    # Cluster info: version, environment, uptime curl -s $COORDINATOR/v1/info | jq .
  • Network accessline 26
    curl -s $COORDINATOR/v1/info | jq .
  • Network accessline 28
    # All registered nodes (coordinator + workers) curl -s $COORDINATOR/v1/node | jq '.[].uri'
  • Network accessline 29
    curl -s $COORDINATOR/v1/node | jq '.[].uri'
  • Network accessline 31
    # Failed nodes (should be empty in healthy cluster) curl -s $COORDINATOR/v1/node/failed | jq .
  • Network accessline 32
    curl -s $COORDINATOR/v1/node/failed | jq .
  • Network accessline 34
    # Cluster-level stats: running queries, blocked queries, active workers curl -s $COORDINATOR/v1/cluster | jq .
  • Network accessline 35
    curl -s $COORDINATOR/v1/cluster | jq .
  • Network accessline 37
    # All active queries with state curl -s -H "X-Trino-User: admin" $COORDINATOR/v1/query | jq '.[] | {queryId, state, query}'
  • Network accessline 38
    curl -s -H "X-Trino-User: admin" $COORDINATOR/v1/query | jq '.[] | {queryId, state, query}'
  • Network accessline 40
    # Specific query details curl -s -H "X-Trino-User: admin" $COORDINATOR/v1/query/<query_id> | jq .
  • Network accessline 41
    curl -s -H "X-Trino-User: admin" $COORDINATOR/v1/query/<query_id> | jq .
  • Network accessline 43
    # Kill a query curl -X DELETE -H "X-Trino-User: admin" $COORDINATOR/v1/query/<query_id>
  • Network accessline 44
    curl -X DELETE -H "X-Trino-User: admin" $COORDINATOR/v1/query/<query_id>
  • Network accessline 52
    # Worker count and health curl -s $COORDINATOR/v1/cluster | jq '{
  • Network accessline 53
    curl -s $COORDINATOR/v1/cluster | jq '{
  • Network accessline 60
    # Check if coordinator is ready to serve requests curl -s $COORDINATOR/v1/info/state
  • Network accessline 61
    curl -s $COORDINATOR/v1/info/state
  • Network accessline 172
    # Find all BLOCKED queries (may indicate memory/resource pressure) curl -s -H "X-Trino-User: admin" $COORDINATOR/v1/query \
  • Network accessline 173
    curl -s -H "X-Trino-User: admin" $COORDINATOR/v1/query \
  • Network accessline 176
    # Find long-running queries (running > 10 minutes) curl -s -H "X-Trino-User: admin" $COORDINATOR/v1/query \
  • Network accessline 177
    curl -s -H "X-Trino-User: admin" $COORDINATOR/v1/query \
  • Network accessline 181
    # Count queries by state curl -s -H "X-Trino-User: admin" $COORDINATOR/v1/query \
  • Network accessline 182
    curl -s -H "X-Trino-User: admin" $COORDINATOR/v1/query \
  • Network accessline 229
    # 1. Put worker in graceful shutdown mode (new queries won't be scheduled) curl -X PUT -H "Content-Type: application/json" \
  • Network accessline 230
    curl -X PUT -H "Content-Type: application/json" \
  • Network accessline 231
    http://worker-host:8080/v1/info/state \
  • Network accessline 234
    # 2. Wait for all tasks to finish (poll until running tasks = 0) watch -n 5 'curl -s http://worker-host:8080/v1/info/state'
  • Network accessline 235
    watch -n 5 'curl -s http://worker-host:8080/v1/info/state'
  • Network accessline 255
    # JVM heap usage (should be < 80% of -Xmx) curl -s http://worker:8080/v1/jmx/mbean/java.lang:type=Memory \
  • Network accessline 256
    curl -s http://worker:8080/v1/jmx/mbean/java.lang:type=Memory \
  • Network accessline 259
    # Number of active tasks curl -s http://worker:8080/v1/task | jq 'length'
  • Network accessline 260
    curl -s http://worker:8080/v1/task | jq 'length'
  • Network accessline 262
    # Worker is registered with coordinator curl -s http://coordinator:8080/v1/node | jq '.[].uri' | grep worker-host
  • Network accessline 263
    curl -s http://coordinator:8080/v1/node | jq '.[].uri' | grep worker-host
  • Network accessline 270
    Navigate to `http://trino-coordinator:8080/ui/`:

group_skills/trino_group_skills/trino_dbt_platform/SKILL.md

  • Access to secretsline 81
    [Credential-related source omitted]

group_skills/trino_group_skills/trino_docker_compose_stack/SKILL.md

  • Access to secretsline 22
    [Credential-related source omitted]
  • Network accessline 81
    - lakehouse     healthcheck:       test:     ["CMD", "curl", "-f", "http://localhost:9000/minio/health/live"]
  • Network accessline 82
    healthcheck:       test:     ["CMD", "curl", "-f", "http://localhost:9000/minio/health/live"]       interval: 10s
  • Network accessline 83
    test:     ["CMD", "curl", "-f", "http://localhost:9000/minio/health/live"]
  • Network accessline 94
    [Credential-related source omitted]
  • Network accessline 95
    [Credential-related source omitted]
  • Network accessline 96
    [Credential-related source omitted]
  • Network accessline 171
    - lakehouse     healthcheck:       test:     ["CMD", "curl", "-f", "http://localhost:8080/v1/info/state"]
  • Network accessline 172
    healthcheck:       test:     ["CMD", "curl", "-f", "http://localhost:8080/v1/info/state"]       interval: 15s
  • Network accessline 173
    test:     ["CMD", "curl", "-f", "http://localhost:8080/v1/info/state"]
  • Access to secretsline 224
    [Credential-related source omitted]
  • Access to secretsline 248
    [Credential-related source omitted]
  • Network accessline 292
    node-scheduler.include-coordinator=false http-server.http.port=8080 discovery.uri=http://trino-coordinator:8080
  • Network accessline 293
    http-server.http.port=8080 discovery.uri=http://trino-coordinator:8080 query.max-memory=2GB
  • Network accessline 294
    discovery.uri=http://trino-coordinator:8080
  • Network accessline 326
    coordinator=false http-server.http.port=8080 discovery.uri=http://trino-coordinator:8080
  • Network accessline 327
    http-server.http.port=8080 discovery.uri=http://trino-coordinator:8080 query.max-memory-per-node=1GB
  • Network accessline 328
    discovery.uri=http://trino-coordinator:8080
  • Network accessline 337
    hive.metastore.uri=thrift://hive-metastore:9083 hive.s3.path-style-access=true hive.s3.endpoint=http://minio:9000
  • Network accessline 338
    hive.s3.path-style-access=true hive.s3.endpoint=http://minio:9000 hive.s3.aws-access-key=minioadmin
  • Network accessline 339
    hive.s3.endpoint=http://minio:9000
  • Network accessline 360
    <property>     <name>fs.s3a.endpoint</name>     <value>http://minio:9000</value>
  • Network accessline 361
    <name>fs.s3a.endpoint</name>     <value>http://minio:9000</value>   </property>
  • Network accessline 362
    <value>http://minio:9000</value>
  • Access to secretsline 401
    [Credential-related source omitted]
  • Access to secretsline 404
    [Credential-related source omitted]
  • Network accessline 432
    # Access UIs: # Trino:      http://localhost:8080
  • Network accessline 433
    # Trino:      http://localhost:8080
  • Network accessline 434
    # Airflow:    http://localhost:8081  (admin/admin)
  • Network accessline 435
    # MinIO:      http://localhost:9001  (minioadmin/minioadmin)
  • Network accessline 436
    # Superset:   http://localhost:8088  (admin/admin)
  • Network accessline 437
    # Grafana:    http://localhost:3000  (admin/admin)
  • Network accessline 438
    # Prometheus: http://localhost:9090

group_skills/trino_group_skills/trino_lakehouse_platform_architect/SKILL.md

  • Network accessline 59
    node-scheduler.include-coordinator=false   # never schedule work on coordinator http-server.http.port=8080 discovery.uri=http://trino-coordinator:8080
  • Network accessline 60
    http-server.http.port=8080 discovery.uri=http://trino-coordinator:8080 query.max-memory=50GB
  • Network accessline 61
    discovery.uri=http://trino-coordinator:8080
  • Network accessline 73
    coordinator=false http-server.http.port=8080 discovery.uri=http://trino-coordinator:8080
  • Network accessline 75
    discovery.uri=http://trino-coordinator:8080
  • Network accessline 117
    hive.metastore.uri=thrift://hive-metastore:9083 hive.s3.path-style-access=true hive.s3.endpoint=http://minio:9000
  • Network accessline 118
    hive.s3.path-style-access=true hive.s3.endpoint=http://minio:9000 hive.s3.aws-access-key=minio_access
  • Network accessline 119
    hive.s3.endpoint=http://minio:9000

group_skills/trino_group_skills/trino_memory_and_spill_tuning/SKILL.md

  • Access to secretsline 171
    [Credential-related source omitted]
  • Access to secretsline 172
    [Credential-related source omitted]
  • Network accessline 194
    # 2. Find which query consumed the most memory (via REST) curl -s http://coordinator:8080/v1/query \
  • Network accessline 195
    curl -s http://coordinator:8080/v1/query \
  • Network accessline 199
    # 3. Get detailed memory usage for a specific query curl -s http://coordinator:8080/v1/query/<query_id> \
  • Network accessline 200
    curl -s http://coordinator:8080/v1/query/<query_id> \
  • Network accessline 207
    # 4. Check heap usage via JMX curl -s http://worker:8080/v1/jmx/mbean/java.lang:type=Memory \
  • Network accessline 208
    curl -s http://worker:8080/v1/jmx/mbean/java.lang:type=Memory \

group_skills/trino_group_skills/trino_modern_data_stack_reference_architecture/SKILL.md

  • Network accessline 134
    entrypoint: >       /bin/sh -c "         mc alias set local http://minio:9000 minioadmin minioadmin123;
  • Network accessline 135
    /bin/sh -c "         mc alias set local http://minio:9000 minioadmin minioadmin123;         mc mb --ignore-existing local/warehouse;
  • Network accessline 136
    mc alias set local http://minio:9000 minioadmin minioadmin123;
  • Network accessline 198
    - ./trino/catalog:/etc/trino/catalog:ro     healthcheck:       test: ["CMD", "curl", "-f", "http://localhost:8080/v1/info/state"]
  • Network accessline 199
    healthcheck:       test: ["CMD", "curl", "-f", "http://localhost:8080/v1/info/state"]       interval: 15s
  • Network accessline 200
    test: ["CMD", "curl", "-f", "http://localhost:8080/v1/info/state"]
  • Network accessline 323
    node-scheduler.include-coordinator=false http-server.http.port=8080 discovery.uri=http://trino-coordinator:8080
  • Network accessline 325
    discovery.uri=http://trino-coordinator:8080
  • Network accessline 362
    coordinator=false http-server.http.port=8080 discovery.uri=http://trino-coordinator:8080
  • Network accessline 364
    discovery.uri=http://trino-coordinator:8080
  • Network accessline 380
    # S3/MinIO storage hive.s3.endpoint=http://minio:9000
  • Network accessline 381
    hive.s3.endpoint=http://minio:9000
  • Network accessline 420
    <property>     <name>fs.s3a.endpoint</name>     <value>http://minio:9000</value>
  • Network accessline 421
    <name>fs.s3a.endpoint</name>     <value>http://minio:9000</value>   </property>
  • Network accessline 422
    <value>http://minio:9000</value>
  • Network accessline 990
    # Bootstrap Iceberg schemas docker exec trino-coordinator trino \   --server http://localhost:8080 \
  • Network accessline 991
    docker exec trino-coordinator trino    --server http://localhost:8080
  • Network accessline 992
    --server http://localhost:8080 \
  • Network accessline 1001
    # Trigger Airflow DAGs open http://localhost:8080   # Airflow UI  (admin/admin)
  • Network accessline 1002
    open http://localhost:8080   # Airflow UI  (admin/admin)
  • Network accessline 1003
    open http://localhost:8088   # Superset    (admin/admin)
  • Network accessline 1004
    open http://localhost:3000   # Grafana     (admin/admin)
  • Network accessline 1005
    open http://localhost:8080   # Trino Web UI
  • Network accessline 1050
    iceberg.catalog.type=glue     hive.metastore.glue.region=us-east-1     hive.s3.endpoint=https://s3.us-east-1.amazonaws.com
  • Network accessline 1051
    hive.metastore.glue.region=us-east-1     hive.s3.endpoint=https://s3.us-east-1.amazonaws.com     iceberg.file-format=PARQUET
  • Network accessline 1052
    hive.s3.endpoint=https://s3.us-east-1.amazonaws.com
  • Access to secretsline 1060
    [Credential-related source omitted]
  • Network accessline 1075
    # 1. Confirm coordinator is active curl -s http://trino:8080/v1/info/state | tr -d '"'   # → ACTIVE
  • Network accessline 1076
    curl -s http://trino:8080/v1/info/state | tr -d '"'   # → ACTIVE
  • Network accessline 1078
    # 2. Check worker count curl -s http://trino:8080/v1/node | python3 -c "import sys,json; print(len(json.load(sys.stdin)),'workers')"
  • Dangerous shell operationline 1079
    curl -s http://trino:8080/v1/node | python3 -c "import sys,json; print(len(json.load(sys.stdin)),'workers')"
  • Network accessline 1079
    curl -s http://trino:8080/v1/node | python3 -c "import sys,json; print(len(json.load(sys.stdin)),'workers')"
  • Network accessline 1081
    # 3. Check for failed queries in last 1h trino --server http://trino:8080 --execute "
  • Network accessline 1082
    trino --server http://trino:8080 --execute "
  • Network accessline 1088
    # 4. Check Iceberg table health trino --server http://trino:8080 --execute "
  • Network accessline 1089
    trino --server http://trino:8080 --execute "

group_skills/trino_group_skills/trino_observability_platform/SKILL.md

  • Network accessline 152
    annotations:           summary: "Trino active workers = {{ $value }} (minimum: 3)"           runbook: "https://wiki.internal/runbooks/trino-worker-lost"
  • Network accessline 154
    runbook: "https://wiki.internal/runbooks/trino-worker-lost"
  • Network accessline 316
    def find_slow_queries(coordinator_url: str, threshold_sec: int = 60) -> list[dict]:     """Find currently running queries slower than threshold."""     resp = requests.get(
  • Network accessline 317
    """Find currently running queries slower than threshold."""     resp = requests.get(         f"{coordinator_url}/v1/query",
  • Network accessline 318
    resp = requests.get(
  • Network accessline 341
    def get_query_resource_usage(coordinator_url: str, query_id: str) -> dict:     """Get peak memory, CPU time, data scanned for a query."""     resp = requests.get(
  • Network accessline 342
    """Get peak memory, CPU time, data scanned for a query."""     resp = requests.get(         f"{coordinator_url}/v1/query/{query_id}",
  • Network accessline 343
    resp = requests.get(

group_skills/trino_group_skills/trino_production_readiness_review/SKILL.md

  • Network accessline 106
    location / {         proxy_pass         http://trino_cluster;
  • Network accessline 107
    proxy_pass         http://trino_cluster;
  • Network accessline 135
    # Discovery discovery.uri=http://trino-coordinator:8080
  • Network accessline 136
    discovery.uri=http://trino-coordinator:8080
  • Access to secretsline 140
    [Credential-related source omitted]
  • Network accessline 241
    # 1. Signal graceful shutdown   curl -X PUT -H "Content-Type: application/json" \
  • Network accessline 242
    curl -X PUT -H "Content-Type: application/json" \
  • Network accessline 243
    "http://$WORKER:8080/v1/info/state" -d '"SHUTTING_DOWN"'
  • Network accessline 245
    # 2. Wait until all tasks drain (check every 10s, max 10 min)   timeout 600 bash -c "     while [ \"\$(curl -s http://$WORKER:8080/v1/info/state)\" != '\"INACTIVE\"' ]; do
  • Network accessline 246
    timeout 600 bash -c "     while [ \"\$(curl -s http://$WORKER:8080/v1/info/state)\" != '\"INACTIVE\"' ]; do       sleep 10
  • Network accessline 247
    while [ \"\$(curl -s http://$WORKER:8080/v1/info/state)\" != '\"INACTIVE\"' ]; do
  • Dangerous shell operationline 253
    ssh $WORKER "sudo systemctl stop trino && sudo apt install trino-server=481 && sudo systemctl start trino"
  • Network accessline 290
    COORDINATOR="http://trino-coordinator:8080"
  • Network accessline 305
    # Check coordinator state STATE=$(curl -s "$COORDINATOR/v1/info/state" | tr -d '"')
  • Network accessline 306
    STATE=$(curl -s "$COORDINATOR/v1/info/state" | tr -d '"')
  • Network accessline 309
    # Check worker count WORKERS=$(curl -s "$COORDINATOR/v1/node" | python3 -c "import sys,json; print(len(json.load(sys.stdin)))")
  • Dangerous shell operationline 310
    WORKERS=$(curl -s "$COORDINATOR/v1/node" | python3 -c "import sys,json; print(len(json.load(sys.stdin)))")
  • Network accessline 310
    WORKERS=$(curl -s "$COORDINATOR/v1/node" | python3 -c "import sys,json; print(len(json.load(sys.stdin)))")
  • Network accessline 313
    # Check failed nodes FAILED=$(curl -s "$COORDINATOR/v1/node/failed" | python3 -c "import sys,json; print(len(json.load(sys.stdin)))")
  • Dangerous shell operationline 314
    FAILED=$(curl -s "$COORDINATOR/v1/node/failed" | python3 -c "import sys,json; print(len(json.load(sys.stdin)))")
  • Network accessline 314
    FAILED=$(curl -s "$COORDINATOR/v1/node/failed" | python3 -c "import sys,json; print(len(json.load(sys.stdin)))")
  • Network accessline 317
    # Check query execution RESULT=$(curl -s -H "X-Trino-User: admin" \
  • Dangerous shell operationline 318
    RESULT=$(curl -s -H "X-Trino-User: admin"    -H "X-Trino-Catalog: tpch"    -H "X-Trino-Schema: sf1"    "$COORDINATOR/v1/statement"    -d "SELECT 1 AS health_check" | python3 -c "import sys,json; d=json.load(sys.stdin); print(d.get('state','
  • Network accessline 318
    RESULT=$(curl -s -H "X-Trino-User: admin" \

group_skills/trino_group_skills/trino_resource_group_governance/SKILL.md

  • Network accessline 243
    trino --server http://coordinator:8080 \
  • Network accessline 294
    # Active group state via JMX (groups with jmxExport: true) curl -s http://coordinator:8080/v1/jmx/mbean/trino.execution:name=QueryManager \
  • Network accessline 295
    curl -s http://coordinator:8080/v1/jmx/mbean/trino.execution:name=QueryManager \
  • Network accessline 298
    # Query resource group assignment curl -s http://coordinator:8080/v1/query/<query_id> \
  • Network accessline 299
    curl -s http://coordinator:8080/v1/query/<query_id> \

group_skills/trino_group_skills/trino_security_and_governance/SKILL.md

  • Access to secretsline 48
    [Credential-related source omitted]
  • Network accessline 82
    # etc/oauth2-http-server-authentication.properties oauth2-http-server-authentication.auth-url=https://auth.company.com/oauth2/authorize
  • Network accessline 83
    oauth2-http-server-authentication.auth-url=https://auth.company.com/oauth2/authorize
  • Network accessline 84
    oauth2-http-server-authentication.token-url=https://auth.company.com/oauth2/token
  • Network accessline 85
    [Credential-related source omitted]
  • Network accessline 86
    [Credential-related source omitted]
  • Access to secretsline 86
    [Credential-related source omitted]
  • Network accessline 87
    oauth2-http-server-authentication.jwks-url=https://auth.company.com/oauth2/jwks
  • Network accessline 351
    # etc/access-control.properties access-control.name=opa opa.policy.uri=http://opa-server:8181/v1/data/trino/allow
  • Network accessline 352
    access-control.name=opa opa.policy.uri=http://opa-server:8181/v1/data/trino/allow opa.policy.batched-uri=http://opa-server:8181/v1/data/trino/batch
  • Network accessline 353
    opa.policy.uri=http://opa-server:8181/v1/data/trino/allow
  • Network accessline 354
    opa.policy.batched-uri=http://opa-server:8181/v1/data/trino/batch

group_skills/trino_group_skills/trino_self_healing_platform/SKILL.md

  • Network accessline 65
    def get_running_queries(self) -> list[dict]:         resp = requests.get(f"{self.coordinator}/v1/query", headers=self.headers, timeout=10)
  • Network accessline 66
    resp = requests.get(f"{self.coordinator}/v1/query", headers=self.headers, timeout=10)
  • Network accessline 92
    def kill_query(self, query_id: str, reason: str) -> bool:         try:             resp = requests.delete(
  • Network accessline 93
    try:             resp = requests.delete(                 f"{self.coordinator}/v1/query/{query_id}",
  • Network accessline 94
    resp = requests.delete(
  • Network accessline 133
    def get_free_memory_pct(self) -> float:         resp = requests.get(f"{self.coordinator}/v1/cluster", headers=self.headers, timeout=5)
  • Network accessline 134
    resp = requests.get(f"{self.coordinator}/v1/cluster", headers=self.headers, timeout=5)
  • Network accessline 140
    def get_queries_by_memory(self) -> list[dict]:         resp = requests.get(f"{self.coordinator}/v1/query", headers=self.headers, timeout=10)
  • Network accessline 141
    resp = requests.get(f"{self.coordinator}/v1/query", headers=self.headers, timeout=10)
  • Network accessline 168
    def kill_query(self, query_id: str, reason: str) -> bool:         resp = requests.delete(
  • Network accessline 169
    resp = requests.delete(
  • Network accessline 300
    # Collect cluster context     cluster_info = requests.get(f"{coordinator_url}/v1/cluster",
  • Network accessline 301
    cluster_info = requests.get(f"{coordinator_url}/v1/cluster",
  • Network accessline 302
    headers={'X-Trino-User': 'watchdog'}).json()     failed_queries = requests.get(f"{coordinator_url}/v1/query",                                   headers={'X-Trino-User': 'watchdog'}).json()
  • Network accessline 303
    failed_queries = requests.get(f"{coordinator_url}/v1/query",
  • Network accessline 360
    coordinator = 'http://trino-coordinator:8080'

skills/airbyte/SKILL.md

  • Network accessline 125
    # Install abctl curl -LsfS https://get.airbyte.com | bash -
  • Dangerous shell operationline 126
    curl -LsfS https://get.airbyte.com | bash -
  • Network accessline 126
    curl -LsfS https://get.airbyte.com | bash -
  • Network accessline 134
    # Access UI at http://localhost:8000
  • Network accessline 147
    # Add Airbyte Helm repo helm repo add airbyte https://airbytehq.github.io/helm-charts
  • Network accessline 148
    helm repo add airbyte https://airbytehq.github.io/helm-charts
  • Network accessline 215
    - Fully managed SaaS at [cloud.airbyte.com](https://cloud.airbyte.com).
  • Network accessline 247
    # List available connector versions curl -X GET "https://api.airbyte.com/v1/sources/{sourceId}" \
  • Network accessline 248
    [Credential-related source omitted]
  • Access to secretsline 248
    [Credential-related source omitted]
  • Access to secretsline 249
    [Credential-related source omitted]
  • Network accessline 251
    # Upgrade connector version (Airbyte Cloud API) curl -X PATCH "https://api.airbyte.com/v1/sources/{sourceId}" \
  • Network accessline 252
    [Credential-related source omitted]
  • Access to secretsline 252
    [Credential-related source omitted]
  • Access to secretsline 253
    [Credential-related source omitted]
  • Network accessline 292
    url_base = "https://api.example.com/v1/"
  • Access to secretsline 327
    [Credential-related source omitted]
  • Access to secretsline 336
    [Credential-related source omitted]
  • Network accessline 353
    url_base = "https://api.example.com/v1/"
  • Network accessline 411
    auth = Oauth2Authenticator(     token_refresh_endpoint="https://api.example.com/oauth/token",
  • Network accessline 412
    token_refresh_endpoint="https://api.example.com/oauth/token",
  • Access to secretsline 414
    [Credential-related source omitted]
  • Access to secretsline 521
    [Credential-related source omitted]
  • Network accessline 528
    [Credential-related source omitted]
  • Access to secretsline 528
    [Credential-related source omitted]
  • Access to secretsline 529
    [Credential-related source omitted]
  • Network accessline 556
    [Credential-related source omitted]
  • Access to secretsline 556
    [Credential-related source omitted]
  • Access to secretsline 557
    [Credential-related source omitted]
  • Network accessline 582
    [Credential-related source omitted]
  • Access to secretsline 582
    [Credential-related source omitted]
  • Access to secretsline 583
    [Credential-related source omitted]
  • Network accessline 616
    [Credential-related source omitted]
  • Access to secretsline 616
    [Credential-related source omitted]
  • Access to secretsline 617
    [Credential-related source omitted]
  • Access to secretsline 643
    [Credential-related source omitted]
  • Network accessline 645
    [Credential-related source omitted]
  • Network accessline 646
    [Credential-related source omitted]
  • Network accessline 647
    # server_url = "http://airbyte.internal:8000/api/public"
  • Network accessline 796
    [Credential-related source omitted]
  • Access to secretsline 796
    [Credential-related source omitted]
  • Network accessline 797
    BASE = "https://api.airbyte.com/v1"
  • Access to secretsline 798
    [Credential-related source omitted]
  • Network accessline 801
    def get_connection_status(connection_id: str) -> dict:     resp = requests.get(f"{BASE}/connections/{connection_id}", headers=HEADERS)
  • Network accessline 802
    resp = requests.get(f"{BASE}/connections/{connection_id}", headers=HEADERS)
  • Network accessline 807
    def list_recent_jobs(connection_id: str, limit: int = 10) -> list:     resp = requests.get(
  • Network accessline 808
    resp = requests.get(
  • Network accessline 836
    PUBLISH_METRICS: "true"     METRIC_CLIENT: "otel"     OTEL_COLLECTOR_ENDPOINT: "http://otel-collector:4317"
  • Network accessline 838
    OTEL_COLLECTOR_ENDPOINT: "http://otel-collector:4317"
  • Network accessline 972
    - [Airbyte Documentation](https://docs.airbyte.com/)
  • Network accessline 973
    - [Sync Modes Reference](https://docs.airbyte.com/platform/using-airbyte/core-concepts/sync-modes)
  • Network accessline 974
    - [Schema Change Management](https://docs.airbyte.com/platform/using-airbyte/schema-change-management)
  • Network accessline 975
    - [abctl Deployment Guide](https://docs.airbyte.com/platform/deploying-airbyte/abctl)
  • Network accessline 976
    - [Helm Chart V2 (Community)](https://docs.airbyte.com/platform/deploying-airbyte/chart-v2-community)
  • Network accessline 977
    - [Python CDK Overview](https://docs.airbyte.com/platform/connector-development/cdk-python)
  • Network accessline 978
    - [HTTP Streams (CDK)](https://docs.airbyte.com/platform/connector-development/cdk-python/http-streams)
  • Network accessline 979
    - [Incremental Streams (CDK)](https://docs.airbyte.com/connector-development/cdk-python/incremental-stream/)
  • Network accessline 980
    - [Low-Code Connector Builder](https://docs.airbyte.com/platform/connector-development/config-based/low-code-cdk-overview)
  • Network accessline 981
    - [Airbyte Terraform Provider](https://docs.airbyte.com/platform/terraform-documentation)
  • Network accessline 982
    - [Terraform Provider Registry](https://registry.terraform.io/providers/airbytehq/airbyte/latest/docs)
  • Network accessline 983
    - [Airflow Provider — AirbyteTriggerSyncOperator](https://airflow.apache.org/docs/apache-airflow-providers-airbyte/stable/operators/airbyte.html)
  • Network accessline 984
    - [OpenTelemetry Metrics Monitoring](https://docs.airbyte.com/platform/operator-guides/open-telemetry)
  • Network accessline 985
    - [Airbyte Connector Catalog](https://airbyte.com/connectors)
  • Network accessline 986
    - [Airbyte API Reference](https://reference.airbyte.com/)

skills/airflow_dag_factory/SKILL.md

  • Network accessline 10
    > **Package**: `dag-factory` on PyPI   > **Repo**: https://github.com/astronomer/dag-factory
  • Network accessline 11
    > **Repo**: https://github.com/astronomer/dag-factory
  • Network accessline 12
    > **Docs**: https://astronomer.github.io/dag-factory/latest/
  • Access to secretsline 553
    [Credential-related source omitted]
  • Network accessline 1005
    - GitHub: https://github.com/astronomer/dag-factory
  • Network accessline 1006
    - Docs: https://astronomer.github.io/dag-factory/latest/
  • Network accessline 1007
    - PyPI: https://pypi.org/project/dag-factory/
  • Network accessline 1008
    - Migration guide: https://astronomer.github.io/dag-factory/latest/migration_guide/

skills/airflow_dag_factory/reference/migration.md

  • Network accessline 207
    - Official migration guide: https://astronomer.github.io/dag-factory/latest/migration_guide/
  • Network accessline 208
    - dag-factory v1.0 release notes: https://github.com/astronomer/dag-factory/releases/tag/v1.0.0

skills/airflow_dags/SKILL.md

  • Network accessline 719
    # Connections: @task def fetch():
  • Network accessline 720
    @task def fetch():     conn = Connection.get("trino_default")
  • Network accessline 721
    def fetch():
  • Network accessline 1030
    - [Apache Airflow Docs — DAGs](https://airflow.apache.org/docs/apache-airflow/stable/core-concepts/dags.html)
  • Network accessline 1031
    - [Apache Airflow Docs — TaskFlow API](https://airflow.apache.org/docs/apache-airflow/stable/tutorial/taskflow.html)
  • Network accessline 1032
    - [Apache Airflow Docs — Dynamic Task Mapping](https://airflow.apache.org/docs/apache-airflow/stable/core-concepts/dynamic-task-mapping.html)
  • Network accessline 1033
    - [Apache Airflow Best Practices](https://airflow.apache.org/docs/apache-airflow/stable/best-practices.html)
  • Network accessline 1034
    - [Astronomer — DAG Writing Best Practices](https://www.astronomer.io/docs/learn/airflow-dag-writing-best-practices)
  • Network accessline 1035
    - [Astronomer — Dynamic Tasks Guide](https://www.astronomer.io/docs/learn/dynamic-tasks)
  • Network accessline 1036
    - [Astronomer — TaskGroups Guide](https://www.astronomer.io/docs/learn/task-groups)
  • Network accessline 1037
    - [Astronomer — Airflow Pools Guide](https://www.astronomer.io/docs/learn/airflow-pools)

skills/apache_flink/SKILL.md

  • Network accessline 229
    'type'         = 'iceberg',     'catalog-type' = 'rest',     'uri'          = 'http://iceberg-rest:8181',
  • Network accessline 230
    'catalog-type' = 'rest',     'uri'          = 'http://iceberg-rest:8181',     'warehouse'    = 's3://datalake/'
  • Network accessline 231
    'uri'          = 'http://iceberg-rest:8181',
  • Network accessline 586
    # Get job overview curl http://jobmanager:8081/jobs/<job-id>
  • Network accessline 587
    curl http://jobmanager:8081/jobs/<job-id>
  • Network accessline 678
    state.backend: rocksdb         state.checkpoints.dir: s3://checkpoints/         s3.endpoint: http://minio:9000
  • Network accessline 679
    state.checkpoints.dir: s3://checkpoints/         s3.endpoint: http://minio:9000         s3.access-key: minioadmin
  • Network accessline 680
    s3.endpoint: http://minio:9000
  • Network accessline 724
    # REST API — check job status curl http://jobmanager:8081/jobs/overview
  • Network accessline 725
    curl http://jobmanager:8081/jobs/overview
  • Network accessline 727
    # Per-vertex backpressure status (0.0 = none, 1.0 = fully backpressured) curl http://jobmanager:8081/jobs/<job-id>/vertices/<vertex-id>/backpressure
  • Network accessline 728
    curl http://jobmanager:8081/jobs/<job-id>/vertices/<vertex-id>/backpressure
  • Network accessline 730
    # Checkpoint statistics curl http://jobmanager:8081/jobs/<job-id>/checkpoints
  • Network accessline 731
    curl http://jobmanager:8081/jobs/<job-id>/checkpoints
  • Network accessline 733
    # Task manager metrics curl http://jobmanager:8081/taskmanagers/<tm-id>/metrics
  • Network accessline 734
    curl http://jobmanager:8081/taskmanagers/<tm-id>/metrics
  • Network accessline 785
    - [Apache Flink Documentation 1.20](https://nightlies.apache.org/flink/flink-docs-release-1.20/)
  • Network accessline 786
    - [PyFlink Table API Tutorial](https://nightlies.apache.org/flink/flink-docs-release-1.20/docs/dev/python/table_api_tutorial/)
  • Network accessline 787
    - [Flink SQL Kafka Connector](https://nightlies.apache.org/flink/flink-docs-release-1.20/docs/connectors/table/kafka/)
  • Network accessline 788
    - [Flink Windowing](https://nightlies.apache.org/flink/flink-docs-release-1.20/docs/dev/datastream/operators/windows/)
  • Network accessline 789
    - [Flink State & Fault Tolerance](https://nightlies.apache.org/flink/flink-docs-release-1.20/docs/concepts/stateful-stream-processing/)
  • Network accessline 790
    - [Flink Kubernetes Operator](https://nightlies.apache.org/flink/flink-kubernetes-operator-docs-release-1.10/)

skills/apache_kafka/SKILL.md

  • Access to secretsline 81
    [Credential-related source omitted]
  • Network accessline 339
    schema_registry_conf = {"url": "http://schema-registry:8081"}
  • Network accessline 379
    # Check compatibility before registering curl -X POST http://schema-registry:8081/compatibility/subjects/orders-value/versions/latest \
  • Network accessline 380
    curl -X POST http://schema-registry:8081/compatibility/subjects/orders-value/versions/latest \
  • Network accessline 428
    "iceberg.tables": "silver.orders",     "iceberg.catalog": "rest",     "iceberg.catalog.uri": "http://iceberg-rest:8181",
  • Network accessline 429
    "iceberg.catalog": "rest",     "iceberg.catalog.uri": "http://iceberg-rest:8181",     "iceberg.tables.upsert-mode-enabled": "true",
  • Network accessline 430
    "iceberg.catalog.uri": "http://iceberg-rest:8181",
  • Network accessline 474
    # Deploy connector curl -X POST http://connect:8083/connectors \
  • Network accessline 475
    curl -X POST http://connect:8083/connectors \
  • Network accessline 479
    # Check status curl http://connect:8083/connectors/postgres-source/status
  • Network accessline 480
    curl http://connect:8083/connectors/postgres-source/status
  • Network accessline 482
    # Restart failed task curl -X POST http://connect:8083/connectors/postgres-source/tasks/0/restart
  • Network accessline 483
    curl -X POST http://connect:8083/connectors/postgres-source/tasks/0/restart
  • Network accessline 485
    # Update config without restart curl -X PUT http://connect:8083/connectors/postgres-source/config \
  • Network accessline 486
    curl -X PUT http://connect:8083/connectors/postgres-source/config \
  • Network accessline 490
    # Delete connector curl -X DELETE http://connect:8083/connectors/postgres-source
  • Network accessline 491
    curl -X DELETE http://connect:8083/connectors/postgres-source
  • Network accessline 655
    CONNECT_KEY_CONVERTER: org.apache.kafka.connect.json.JsonConverter       CONNECT_VALUE_CONVERTER: io.confluent.connect.avro.AvroConverter       CONNECT_VALUE_CONVERTER_SCHEMA_REGISTRY_URL: http://schema-registry:8081
  • Network accessline 656
    CONNECT_VALUE_CONVERTER: io.confluent.connect.avro.AvroConverter       CONNECT_VALUE_CONVERTER_SCHEMA_REGISTRY_URL: http://schema-registry:8081       CONNECT_REST_ADVERTISED_HOST_NAME: kafka-connect
  • Network accessline 657
    CONNECT_VALUE_CONVERTER_SCHEMA_REGISTRY_URL: http://schema-registry:8081
  • Network accessline 665
    KAFKA_CLUSTERS_0_NAME: local       KAFKA_CLUSTERS_0_BOOTSTRAPSERVERS: broker:9092       KAFKA_CLUSTERS_0_SCHEMAREGISTRY: http://schema-registry:8081
  • Network accessline 666
    KAFKA_CLUSTERS_0_BOOTSTRAPSERVERS: broker:9092       KAFKA_CLUSTERS_0_SCHEMAREGISTRY: http://schema-registry:8081       KAFKA_CLUSTERS_0_KAFKACONNECT_0_NAME: connect
  • Network accessline 667
    KAFKA_CLUSTERS_0_SCHEMAREGISTRY: http://schema-registry:8081
  • Network accessline 668
    KAFKA_CLUSTERS_0_KAFKACONNECT_0_NAME: connect       KAFKA_CLUSTERS_0_KAFKACONNECT_0_ADDRESS: http://kafka-connect:8083     depends_on: [broker]
  • Network accessline 669
    KAFKA_CLUSTERS_0_KAFKACONNECT_0_ADDRESS: http://kafka-connect:8083
  • Network accessline 712
    - [Apache Kafka Documentation](https://kafka.apache.org/documentation/)
  • Network accessline 713
    - [Confluent Kafka Python Client](https://docs.confluent.io/platform/current/clients/confluent-kafka-python/html/index.html)
  • Network accessline 714
    - [Confluent Schema Registry Docs](https://docs.confluent.io/platform/current/schema-registry/index.html)
  • Network accessline 715
    - [Kafka Connect Error Handling & DLQ](https://www.confluent.io/blog/kafka-connect-deep-dive-error-handling-dead-letter-queues/)
  • Network accessline 716
    - [Kafka Production Deployment Guide](https://docs.confluent.io/platform/current/kafka/deployment.html)

skills/cdc_debezium/SKILL.md

  • Network accessline 168
    "key.converter": "io.confluent.kafka.serializers.KafkaAvroSerializer",     "key.converter.schema.registry.url": "http://schema-registry:8081",
  • Network accessline 169
    "key.converter.schema.registry.url": "http://schema-registry:8081",
  • Network accessline 171
    "value.converter.schema.registry.url": "http://schema-registry:8081",
  • Network accessline 264
    "key.converter": "io.confluent.kafka.serializers.KafkaAvroSerializer",     "key.converter.schema.registry.url": "http://schema-registry:8081",
  • Network accessline 265
    "key.converter.schema.registry.url": "http://schema-registry:8081",
  • Network accessline 267
    "value.converter.schema.registry.url": "http://schema-registry:8081",
  • Network accessline 354
    CONNECT_KEY_CONVERTER: io.confluent.kafka.serializers.KafkaAvroSerializer       CONNECT_VALUE_CONVERTER: io.confluent.kafka.serializers.KafkaAvroSerializer       CONNECT_KEY_CONVERTER_SCHEMA_REGISTRY_URL: http://schema-registry:8081
  • Network accessline 355
    CONNECT_VALUE_CONVERTER: io.confluent.kafka.serializers.KafkaAvroSerializer       CONNECT_KEY_CONVERTER_SCHEMA_REGISTRY_URL: http://schema-registry:8081       CONNECT_VALUE_CONVERTER_SCHEMA_REGISTRY_URL: http://schema-registry:8081
  • Network accessline 356
    CONNECT_KEY_CONVERTER_SCHEMA_REGISTRY_URL: http://schema-registry:8081
  • Network accessline 357
    CONNECT_VALUE_CONVERTER_SCHEMA_REGISTRY_URL: http://schema-registry:8081
  • Network accessline 368
    # Deploy connector curl -s -X POST http://localhost:8083/connectors \
  • Network accessline 369
    curl -s -X POST http://localhost:8083/connectors \
  • Network accessline 373
    # Check status curl -s http://localhost:8083/connectors/pg-customers-connector/status | jq
  • Network accessline 374
    curl -s http://localhost:8083/connectors/pg-customers-connector/status | jq
  • Network accessline 376
    # Pause / Resume (drains without losing offset) curl -X PUT http://localhost:8083/connectors/pg-customers-connector/pause
  • Network accessline 377
    curl -X PUT http://localhost:8083/connectors/pg-customers-connector/pause
  • Network accessline 378
    curl -X PUT http://localhost:8083/connectors/pg-customers-connector/resume
  • Network accessline 380
    # Restart failed task curl -X POST "http://localhost:8083/connectors/pg-customers-connector/tasks/0/restart"
  • Network accessline 381
    curl -X POST "http://localhost:8083/connectors/pg-customers-connector/tasks/0/restart"
  • Network accessline 383
    # List all connectors curl -s http://localhost:8083/connectors | jq
  • Network accessline 384
    curl -s http://localhost:8083/connectors | jq
  • Network accessline 386
    # Delete connector (releases replication slot!) curl -X DELETE http://localhost:8083/connectors/pg-customers-connector
  • Network accessline 387
    curl -X DELETE http://localhost:8083/connectors/pg-customers-connector
  • Network accessline 523
    'catalog-name'       = 'rest',     'catalog-type'       = 'rest',     'uri'                = 'http://iceberg-rest:8181',
  • Network accessline 524
    'catalog-type'       = 'rest',     'uri'                = 'http://iceberg-rest:8181',     'warehouse'          = 's3://lakehouse/warehouse',
  • Network accessline 525
    'uri'                = 'http://iceberg-rest:8181',
  • Network accessline 551
    "iceberg.catalog.type": "rest",     "iceberg.catalog.uri": "http://iceberg-rest:8181",
  • Network accessline 552
    "iceberg.catalog.uri": "http://iceberg-rest:8181",

skills/clickhouse_olap/SKILL.md

  • Network accessline 694
    - [ClickHouse MergeTree Documentation](https://clickhouse.com/docs/en/engines/table-engines/mergetree-family/mergetree)
  • Network accessline 695
    - [ClickHouse Best Practices Guide](https://clickhouse.com/docs/en/guides/best-practices/)
  • Network accessline 696
    - [ClickHouse Query Optimization](https://clickhouse.com/docs/en/guides/best-practices/sparse-primary-indexes)
  • Network accessline 697
    - [AggregatingMergeTree](https://clickhouse.com/docs/en/engines/table-engines/mergetree-family/aggregatingmergetree)
  • Network accessline 698
    - [ClickHouse Materialized Views](https://clickhouse.com/docs/en/materialized-view)
  • Network accessline 699
    - [clickhouse-connect Python client](https://clickhouse.com/docs/en/integrations/python)
  • Network accessline 700
    - [Kafka Engine](https://clickhouse.com/docs/en/engines/table-engines/integrations/kafka)

skills/data_contracts/SKILL.md

  • Network accessline 68
    contact:     name: Orders Platform Team     url: https://wiki.example.com/orders
  • Network accessline 69
    name: Orders Platform Team     url: https://wiki.example.com/orders     email: orders-platform@example.com
  • Network accessline 70
    url: https://wiki.example.com/orders
  • Network accessline 71
    email: orders-platform@example.com   links:     data_catalog: https://datahub.example.com/dataset/urn:li:dataset:(urn:li:dataPlatform:kafka,orders.enriched,PROD)
  • Network accessline 72
    links:     data_catalog: https://datahub.example.com/dataset/urn:li:dataset:(urn:li:dataPlatform:kafka,orders.enriched,PROD)     runbook: https://wiki.example.com/orders/runbook
  • Network accessline 73
    data_catalog: https://datahub.example.com/dataset/urn:li:dataset:(urn:li:dataPlatform:kafka,orders.enriched,PROD)
  • Network accessline 74
    runbook: https://wiki.example.com/orders/runbook
  • Network accessline 75
    slack: https://example.slack.com/archives/C0ORDERS
  • Network accessline 82
    limitations: |     PII fields must not be exposed in dashboards without masking. See     https://wiki.example.com/data-classification for the classification guide.
  • Network accessline 83
    PII fields must not be exposed in dashboards without masking. See     https://wiki.example.com/data-classification for the classification guide.   billing: free                          # free | subscription | metered
  • Network accessline 84
    https://wiki.example.com/data-classification for the classification guide.
  • Access to secretsline 359
    [Credential-related source omitted]
  • Network accessline 410
    # Publish test results to a remote URL (webhook / internal platform) datacontract publish datacontract.yaml \   --publish-url https://data-platform.example.com/api/contracts
  • Network accessline 411
    datacontract publish datacontract.yaml    --publish-url https://data-platform.example.com/api/contracts
  • Network accessline 412
    --publish-url https://data-platform.example.com/api/contracts
  • Network accessline 439
    topic: orders.enriched.v2     format: avro                           # avro | json | protobuf | csv     schemaRegistryUrl: https://schema-registry.example.com
  • Network accessline 440
    format: avro                           # avro | json | protobuf | csv     schemaRegistryUrl: https://schema-registry.example.com     partitions: 12
  • Network accessline 441
    schemaRegistryUrl: https://schema-registry.example.com
  • Network accessline 455
    format: parquet     delimiter: none                        # row delimiter for line-delimited formats     endpointUrl: https://s3.amazonaws.com  # override for MinIO or S3-compatible
  • Network accessline 456
    delimiter: none                        # row delimiter for line-delimited formats     endpointUrl: https://s3.amazonaws.com  # override for MinIO or S3-compatible     roles:
  • Network accessline 457
    endpointUrl: https://s3.amazonaws.com  # override for MinIO or S3-compatible
  • Network accessline 746
    # Or use DataHub REST API directly curl -X POST https://datahub.example.com/openapi/v3/entity/datacontract \
  • Network accessline 747
    [Credential-related source omitted]
  • Access to secretsline 747
    [Credential-related source omitted]
  • Access to secretsline 748
    [Credential-related source omitted]
  • Network accessline 766
    # Upload via OpenMetadata REST API curl -X POST https://openmetadata.example.com/api/v1/dataContracts \
  • Network accessline 767
    [Credential-related source omitted]
  • Access to secretsline 767
    [Credential-related source omitted]
  • Access to secretsline 768
    [Credential-related source omitted]
  • Network accessline 803
    - **Data Contract Specification** (datacontract.com): https://datacontract-specification.com/
  • Network accessline 804
    - **Data Contract CLI docs**: https://cli.datacontract.com/
  • Network accessline 805
    - **CLI GitHub repository**: https://github.com/datacontract/datacontract-cli
  • Network accessline 806
    - **Specification GitHub repository**: https://github.com/datacontract/datacontract-specification
  • Network accessline 807
    - **Open Data Contract Standard (ODCS v3)**: https://bitol-io.github.io/open-data-contract-standard/
  • Network accessline 808
    - **DataHub Data Contracts**: https://docs.datahub.com/docs/managed-datahub/observe/data-contract
  • Network accessline 809
    - **OpenMetadata Data Contracts**: https://docs.open-metadata.org/v1.11.x/how-to-guides/data-contracts/spec
  • Network accessline 810
    - **SodaCL reference** (for `quality.specification` authoring): https://docs.soda.io/soda-cl/soda-cl-overview.html
  • Network accessline 811
    - **datacontract-action** (official GitHub Action): https://github.com/datacontract/datacontract-action

skills/data_vault_2/SKILL.md

  • Network accessline 935
    [automate-dv](https://automate-dv.readthedocs.io/) (formerly dbtvault) provides Jinja macros for all DV 2.0 entity types.

skills/datahub_catalog/SKILL.md

  • Network accessline 74
    pip install acryl-datahub datahub docker quickstart          # pulls docker-compose and starts all services # Access UI at http://localhost:9002  (default: datahub / datahub)
  • Network accessline 75
    datahub docker quickstart          # pulls docker-compose and starts all services # Access UI at http://localhost:9002  (default: datahub / datahub) # GMS REST at http://localhost:8080
  • Network accessline 76
    # Access UI at http://localhost:9002  (default: datahub / datahub)
  • Network accessline 77
    # GMS REST at http://localhost:8080
  • Network accessline 107
    helm repo add datahub https://helm.datahubproject.io/
  • Network accessline 210
    type: datahub-rest             # or datahub-kafka for async   config:     server: "http://datahub-gms:8080"
  • Network accessline 211
    [Credential-related source omitted]
  • Network accessline 212
    server: "http://datahub-gms:8080"
  • Access to secretsline 213
    [Credential-related source omitted]
  • Network accessline 247
    type: datahub-rest   config:     server: "http://datahub-gms:8080"
  • Network accessline 249
    server: "http://datahub-gms:8080"
  • Network accessline 268
    type: datahub-rest   config:     server: "http://datahub-gms:8080"
  • Network accessline 270
    server: "http://datahub-gms:8080"
  • Network accessline 283
    #   --packages io.acryl:acryl-spark-lineage:0.2.16     #   --conf spark.extraListeners=datahub.spark.DatahubSparkListener     #   --conf spark.datahub.rest.server=http://datahub-gms:8080
  • Network accessline 285
    #   --conf spark.datahub.rest.server=http://datahub-gms:8080
  • Network accessline 291
    [Credential-related source omitted]
  • Access to secretsline 291
    [Credential-related source omitted]
  • Network accessline 292
    .appName("etl_job") \     .config("spark.extraListeners", "datahub.spark.DatahubSparkListener") \     .config("spark.datahub.rest.server", "http://datahub-gms:8080") \
  • Network accessline 293
    .config("spark.extraListeners", "datahub.spark.DatahubSparkListener") \     .config("spark.datahub.rest.server", "http://datahub-gms:8080") \     .config("spark.datahub.rest.token", os.environ["DATAHUB_TOKEN"]) \
  • Network accessline 294
    .config("spark.datahub.rest.server", "http://datahub-gms:8080") \
  • Access to secretsline 295
    [Credential-related source omitted]
  • Access to secretsline 327
    [Credential-related source omitted]
  • Network accessline 331
    type: datahub-rest   config:     server: "http://datahub-gms:8080"
  • Network accessline 333
    server: "http://datahub-gms:8080"
  • Network accessline 346
    # Airflow Connection (datahub_rest_default): #   conn_type: datahub_rest #   host: http://datahub-gms:8080
  • Network accessline 347
    [Credential-related source omitted]
  • Network accessline 348
    #   host: http://datahub-gms:8080
  • Network accessline 353
    type: airflow   config:     base_url: "http://airflow-webserver:8080"
  • Network accessline 354
    config:     base_url: "http://airflow-webserver:8080"     airflow_connection_id: datahub_rest_default
  • Network accessline 355
    base_url: "http://airflow-webserver:8080"
  • Network accessline 383
    connection:       bootstrap: "kafka-broker:9092"       schema_registry_url: "http://schema-registry:8081"
  • Network accessline 384
    bootstrap: "kafka-broker:9092"       schema_registry_url: "http://schema-registry:8081"     topic_patterns:
  • Network accessline 385
    schema_registry_url: "http://schema-registry:8081"
  • Network accessline 395
    type: datahub-rest   config:     server: "http://datahub-gms:8080"
  • Network accessline 397
    server: "http://datahub-gms:8080"
  • Access to secretsline 412
    [Credential-related source omitted]
  • Network accessline 418
    type: datahub-rest   config:     server: "http://datahub-gms:8080"
  • Network accessline 420
    server: "http://datahub-gms:8080"
  • Access to secretsline 431
    [Credential-related source omitted]
  • Access to secretsline 432
    [Credential-related source omitted]
  • Network accessline 481
    emitter = DatahubRestEmitter(     gms_server="http://datahub-gms:8080",
  • Network accessline 482
    gms_server="http://datahub-gms:8080",
  • Network accessline 744
    # Search datasets by keyword curl -s \
  • Network accessline 745
    [Credential-related source omitted]
  • Access to secretsline 745
    [Credential-related source omitted]
  • Network accessline 746
    [Credential-related source omitted]
  • Access to secretsline 746
    [Credential-related source omitted]
  • Network accessline 747
    "http://datahub-gms:8080/entities?action=search" \
  • Network accessline 757
    # Get entity aspects curl -s \
  • Network accessline 758
    [Credential-related source omitted]
  • Access to secretsline 758
    [Credential-related source omitted]
  • Network accessline 759
    [Credential-related source omitted]
  • Access to secretsline 759
    [Credential-related source omitted]
  • Network accessline 760
    "http://datahub-gms:8080/entities/urn%3Ali%3Adataset%3A%28urn%3Ali%3AdataPlatform%3Apostgres%2Canalytics.public.orders%2CPROD%29" \
  • Network accessline 766
    DataHub exposes a full GraphQL API at `http://datahub-frontend:9002/api/graphql`.
  • Network accessline 856
    }     """     resp = requests.post(
  • Network accessline 857
    """     resp = requests.post(         "http://datahub-frontend:9002/api/graphql",
  • Network accessline 858
    resp = requests.post(
  • Network accessline 859
    "http://datahub-frontend:9002/api/graphql",
  • Access to secretsline 861
    [Credential-related source omitted]
  • Network accessline 899
    type: datahub-rest   config:     server: "http://datahub-gms:8080"
  • Network accessline 900
    [Credential-related source omitted]
  • Network accessline 901
    server: "http://datahub-gms:8080"
  • Access to secretsline 902
    [Credential-related source omitted]
  • Access to secretsline 931
    [Credential-related source omitted]
  • Network accessline 953
    Create Airflow connection (`datahub_rest_default`): - Connection Type: `datahub_rest` - Host: `http://datahub-gms:8080`
  • Network accessline 954
    [Credential-related source omitted]
  • Network accessline 955
    - Host: `http://datahub-gms:8080`
  • Network accessline 968
    # Or via environment variable export DATAHUB_GMS_URL=http://datahub-gms:8080
  • Network accessline 969
    export DATAHUB_GMS_URL=http://datahub-gms:8080
  • Access to secretsline 970
    [Credential-related source omitted]
  • Network accessline 1138
    type: datahub-rest   config:     server: "http://datahub-gms:8080"
  • Network accessline 1140
    server: "http://datahub-gms:8080"
  • Access to secretsline 1147
    [Credential-related source omitted]

skills/dbt_core/SKILL.md

  • Network accessline 715
    - [dbt Core Documentation](https://docs.getdbt.com/)
  • Network accessline 716
    - [dbt Incremental Models](https://docs.getdbt.com/docs/build/incremental-models)
  • Network accessline 717
    - [dbt Snapshots](https://docs.getdbt.com/docs/build/snapshots)
  • Network accessline 718
    - [dbt Tests](https://docs.getdbt.com/docs/build/data-tests)
  • Network accessline 719
    - [dbt Node Selection](https://docs.getdbt.com/reference/node-selection/syntax)
  • Network accessline 720
    - [dbt-utils package](https://hub.getdbt.com/dbt-labs/dbt_utils/latest/)
  • Network accessline 721
    - [dbt-expectations package](https://hub.getdbt.com/calogica/dbt_expectations/latest/)

skills/dbt_trino/SKILL.md

  • Access to secretsline 102
    [Credential-related source omitted]
  • Network accessline 974
    - dbt + Trino setup: https://docs.getdbt.com/docs/core/connect-data-platform/trino-setup
  • Network accessline 975
    - Trino-specific configs: https://docs.getdbt.com/reference/resource-configs/trino-configs
  • Network accessline 976
    - dbt-trino adapter: https://github.com/starburstdata/dbt-trino
  • Network accessline 977
    - dbt incremental models: https://docs.getdbt.com/docs/build/incremental-models

skills/de_adr/SKILL.md

  • Network accessline 991
    - `skills/kubernetes_data/SKILL.md` — Spark-on-K8s, KubernetesExecutor, Secrets management, RBAC (relevant to ADR-003, ADR-009) - `skills/medallion_architecture/SKILL.md` — Bronze/Silver/Gold layers, CDC micro-batch, schema evolution (relev
  • Network accessline 992
    - `skills/medallion_architecture/SKILL.md` — Bronze/Silver/Gold layers, CDC micro-batch, schema evolution (relevant to ADR-001, ADR-002) - [ADR GitHub repository — Joel Parker Henderson](https://github.com/joelparkerhenderson/architecture-d
  • Network accessline 993
    - [ADR GitHub repository — Joel Parker Henderson](https://github.com/joelparkerhenderson/architecture-decision-record) — extensive ADR template collection
  • Network accessline 994
    - [adr-tools CLI](https://github.com/npryce/adr-tools) — command-line tool for creating and managing ADRs
  • Network accessline 995
    - [log4brains](https://github.com/thomvaill/log4brains) — ADR web UI and static site generator
  • Network accessline 996
    - [Documenting Architecture Decisions — Michael Nygard (original 2011 post)](https://cognitect.com/blog/2011/11/15/documenting-architecture-decisions)
  • Network accessline 997
    - [Architecture Decision Records in Practice — ThoughtWorks Technology Radar](https://www.thoughtworks.com/en-us/radar/techniques/architecture-decision-records)

skills/de_cost_optimization/SKILL.md

  • Network accessline 553
    while not _INTERRUPTED.is_set():         try:             url = "http://169.254.169.254/latest/meta-data/spot/interruption-action"
  • Network accessline 554
    try:             url = "http://169.254.169.254/latest/meta-data/spot/interruption-action"             with urllib.request.urlopen(url, timeout=1) as r:
  • Network accessline 555
    url = "http://169.254.169.254/latest/meta-data/spot/interruption-action"             with urllib.request.urlopen(url, timeout=1) as r:                 action = r.read().decode()
  • Network accessline 556
    with urllib.request.urlopen(url, timeout=1) as r:
  • Network accessline 1415
    - `skills/kubernetes_data/SKILL.md` — Spark-on-K8s, resource quotas, LimitRange, pod labels for cost tools - `skills/github_actions_dataops/SKILL.md` — OIDC for AWS (no static keys), CI/CD cost gates - [AWS Cost Optimization Pillar — Well-A
  • Network accessline 1416
    - `skills/github_actions_dataops/SKILL.md` — OIDC for AWS (no static keys), CI/CD cost gates - [AWS Cost Optimization Pillar — Well-Architected Framework](https://docs.aws.amazon.com/wellarchitected/latest/cost-optimization-pillar/welcome.h
  • Network accessline 1417
    - [AWS Cost Optimization Pillar — Well-Architected Framework](https://docs.aws.amazon.com/wellarchitected/latest/cost-optimization-pillar/welcome.html)
  • Network accessline 1418
    - [AWS Spot Instance Best Practices](https://docs.aws.amazon.com/AWSEC2/latest/UserGuide/spot-best-practices.html)
  • Network accessline 1419
    - [Delta Lake OPTIMIZE Documentation](https://docs.delta.io/latest/optimizations-oss.html)
  • Network accessline 1420
    - [Iceberg Table Maintenance — Apache Docs](https://iceberg.apache.org/docs/latest/maintenance/)
  • Network accessline 1421
    - [FinOps Framework — finops.org](https://www.finops.org/framework/)

skills/de_postmortem/SKILL.md

  • Network accessline 881
    MARQUEZ_URL = "http://marquez:5000"
  • Network accessline 883
    def count_downstream_impact(namespace: str, broken_dataset: str, depth: int = 5) -> dict:     resp = requests.get(
  • Network accessline 884
    resp = requests.get(
  • Network accessline 1226
    - `skills/clickhouse_olap/SKILL.md` — ReplicatedMergeTree mutations, system.mutations table, schema evolution - `skills/delta_lake/SKILL.md` — Time Travel, RESTORE, Change Data Feed for forensic data recovery - [Google SRE Book — Postmortem
  • Network accessline 1227
    - `skills/delta_lake/SKILL.md` — Time Travel, RESTORE, Change Data Feed for forensic data recovery - [Google SRE Book — Postmortem Culture](https://sre.google/sre-book/postmortem-culture/) - [Google SRE Book — Example Postmortem](https://sr
  • Network accessline 1228
    - [Google SRE Book — Postmortem Culture](https://sre.google/sre-book/postmortem-culture/)
  • Network accessline 1229
    - [Google SRE Book — Example Postmortem](https://sre.google/sre-book/example-postmortem/)
  • Network accessline 1230
    - [PagerDuty Incident Response Guide](https://response.pagerduty.com/)
  • Network accessline 1231
    - [Atlassian Incident Management Handbook](https://www.atlassian.com/incident-management/handbook)

skills/de_production_readiness/SKILL.md

  • Network accessline 175
    def fetch_api_data(url: str) -> dict:     import requests     resp = requests.get(url, timeout=10)
  • Network accessline 176
    import requests     resp = requests.get(url, timeout=10)     if resp.status_code == 429:
  • Network accessline 177
    resp = requests.get(url, timeout=10)
  • Network accessline 266
    def _post_slack(text: str):     import requests, os     requests.post(os.environ["SLACK_WEBHOOK_URL"], json={"text": text}, timeout=5)
  • Network accessline 268
    [Credential-related source omitted]
  • Access to secretsline 268
    [Credential-related source omitted]
  • Network accessline 299
    annotations:           summary: "Pipeline {{ $labels.job }} has not completed in 4h"           runbook: "https://wiki.company.com/runbooks/orders_etl"
  • Network accessline 301
    runbook: "https://wiki.company.com/runbooks/orders_etl"
  • Access to secretsline 350
    [Credential-related source omitted]
  • Network accessline 357
    },     }     resp = requests.post(
  • Network accessline 358
    }     resp = requests.post(         "https://events.pagerduty.com/v2/enqueue",
  • Network accessline 359
    resp = requests.post(
  • Network accessline 360
    "https://events.pagerduty.com/v2/enqueue",
  • Network accessline 558
    # Bootstrap once per process (call from DAG or job entrypoint) def setup_tracing(service_name: str, otlp_endpoint: str = "http://otel-collector:4317"):
  • Network accessline 559
    def setup_tracing(service_name: str, otlp_endpoint: str = "http://otel-collector:4317"):
  • Network accessline 811
    def enrich_record(record: dict) -> dict:     def fetch():
  • Network accessline 812
    def fetch():
  • Network accessline 813
    return requests.get(f"https://api.enrichment.io/v1/{record['id']}", timeout=3).json()
  • Network accessline 1018
    - `skills/delta_lake/SKILL.md` — RESTORE, Change Data Feed, OPTIMIZE, Time Travel syntax - `skills/apache_kafka/SKILL.md` — DLQ config, consumer lag monitoring, exactly-once semantics - [Data Engineering Design Patterns — Idempotency (O'Rei
  • Network accessline 1019
    - `skills/apache_kafka/SKILL.md` — DLQ config, consumer lag monitoring, exactly-once semantics - [Data Engineering Design Patterns — Idempotency (O'Reilly)](https://www.oreilly.com/library/view/data-engineering-design/9781098165826/ch04.htm
  • Network accessline 1020
    - [Data Engineering Design Patterns — Idempotency (O'Reilly)](https://www.oreilly.com/library/view/data-engineering-design/9781098165826/ch04.html)
  • Network accessline 1021
    - [Airflow SLA and Retries — Orchestra Guide](https://www.getorchestra.io/guides/airflow-concepts-airflow-sla-and-retries)
  • Network accessline 1022
    - [OpenTelemetry for Data Pipelines — bix-tech.com](https://bix-tech.com/distributed-observability-for-data-pipelines-with-opentelemetry-a-practical-endtoend-playbook-for-2026/)
  • Network accessline 1023
    - [Circuit Breaker Pattern — Azure Architecture Center](https://learn.microsoft.com/en-us/azure/architecture/patterns/circuit-breaker)
  • Network accessline 1024
    - [Soda Data Reconciliation — docs.soda.io](https://docs.soda.io/data-testing/data-reconciliation)

skills/de_rca/SKILL.md

  • Network accessline 857
    MARQUEZ_URL = "http://marquez:5000"
  • Network accessline 859
    def get_downstream_datasets(namespace: str, job_name: str) -> list[dict]:     """Return datasets produced by this job — these are the immediate blast radius."""     resp = requests.get(
  • Network accessline 860
    """Return datasets produced by this job — these are the immediate blast radius."""     resp = requests.get(         f"{MARQUEZ_URL}/api/v1/namespaces/{namespace}/jobs/{job_name}",
  • Network accessline 861
    resp = requests.get(
  • Network accessline 870
    def get_dataset_lineage(namespace: str, dataset_name: str, depth: int = 3) -> dict:     """Get complete upstream + downstream lineage graph for a dataset."""     resp = requests.get(
  • Network accessline 871
    """Get complete upstream + downstream lineage graph for a dataset."""     resp = requests.get(         f"{MARQUEZ_URL}/api/v1/lineage",
  • Network accessline 872
    resp = requests.get(
  • Network accessline 898
    DATAHUB_URL = "http://datahub-gms:8080"
  • Network accessline 919
    def get_downstream_lineage(dataset_urn: str) -> list[str]:     resp = requests.post(
  • Network accessline 920
    resp = requests.post(
  • Network accessline 1144
    - Airflow task logs: `gs://airflow-logs/orders_etl/orders_mart/2024-06-01/1.log` - dbt run_results.json: `s3://artifacts/dbt/2024-06-01/run_results.json` - Grafana dashboard showing row count drop: `https://grafana.internal/d/abc123`
  • Network accessline 1145
    - dbt run_results.json: `s3://artifacts/dbt/2024-06-01/run_results.json` - Grafana dashboard showing row count drop: `https://grafana.internal/d/abc123` - Source schema diff showing field rename: `https://github.com/org/source/pull/456`
  • Network accessline 1146
    - Grafana dashboard showing row count drop: `https://grafana.internal/d/abc123`
  • Network accessline 1147
    - Source schema diff showing field rename: `https://github.com/org/source/pull/456`
  • Network accessline 1297
    - `skills/delta_lake/SKILL.md` — Time Travel (RESTORE, VERSION AS OF), Change Data Feed - `skills/trino_iceberg/SKILL.md` — Iceberg time travel, metadata tables, table maintenance - [Google SRE Book — Postmortem Culture](https://sre.google/
  • Network accessline 1298
    - `skills/trino_iceberg/SKILL.md` — Iceberg time travel, metadata tables, table maintenance - [Google SRE Book — Postmortem Culture](https://sre.google/sre-book/postmortem-culture/) - [Airflow Task Instance States — Apache Docs](https://air
  • Network accessline 1299
    - [Google SRE Book — Postmortem Culture](https://sre.google/sre-book/postmortem-culture/)
  • Network accessline 1300
    - [Airflow Task Instance States — Apache Docs](https://airflow.apache.org/docs/apache-airflow/stable/concepts/tasks.html#task-instances)
  • Network accessline 1301
    - [Spark Troubleshooting Guide — Databricks](https://docs.databricks.com/en/optimizations/troubleshoot-performance.html)
  • Network accessline 1302
    - [dbt run_results.json Schema — dbt Docs](https://docs.getdbt.com/reference/artifacts/run-results-json)

skills/delta_lake/SKILL.md

  • Network accessline 691
    - [Delta Lake Documentation](https://docs.delta.io/latest/index.html)
  • Network accessline 692
    - [Delta Lake Batch Reads & Writes](https://docs.delta.io/latest/delta-batch.html)
  • Network accessline 693
    - [Delta Lake Update/Delete/Merge](https://docs.delta.io/latest/delta-update.html)
  • Network accessline 694
    - [Delta Lake Optimizations](https://docs.delta.io/latest/optimizations-oss.html)
  • Network accessline 695
    - [Delta Lake Utility Operations](https://docs.delta.io/latest/delta-utility.html)
  • Network accessline 696
    - [Delta Lake Streaming](https://docs.delta.io/latest/delta-streaming.html)

skills/docker_data_envs/SKILL.md

  • Dangerous shell operationline 105
    RUN apt-get update && apt-get install -y --no-install-recommends curl tar      && rm -rf /var/lib/apt/lists/*
  • Network accessline 105
    RUN apt-get update && apt-get install -y --no-install-recommends curl tar \
  • Dangerous shell operationline 106
    && rm -rf /var/lib/apt/lists/*
  • Network accessline 108
    RUN curl -fsSL \
  • Network accessline 109
    "https://downloads.apache.org/spark/spark-${SPARK_VERSION}/spark-${SPARK_VERSION}-bin-hadoop${HADOOP_VERSION}.tgz" \
  • Network accessline 118
    # Download connector JARs into the Spark jars directory RUN curl -fsSL -o /opt/spark/jars/iceberg-spark-runtime-3.5_${SCALA_VERSION}-1.6.1.jar \
  • Network accessline 119
    RUN curl -fsSL -o /opt/spark/jars/iceberg-spark-runtime-3.5_${SCALA_VERSION}-1.6.1.jar \
  • Network accessline 120
    "https://repo1.maven.org/maven2/org/apache/iceberg/iceberg-spark-runtime-3.5_${SCALA_VERSION}/1.6.1/iceberg-spark-runtime-3.5_${SCALA_VERSION}-1.6.1.jar" \  && curl -fsSL -o /opt/spark/jars/aws-java-sdk-bundle-1.12.262.jar \     "https://re
  • Network accessline 121
    && curl -fsSL -o /opt/spark/jars/aws-java-sdk-bundle-1.12.262.jar \
  • Network accessline 122
    "https://repo1.maven.org/maven2/com/amazonaws/aws-java-sdk-bundle/1.12.262/aws-java-sdk-bundle-1.12.262.jar"
  • Dangerous shell operationline 144
    RUN apt-get update      && apt-get install -y --no-install-recommends python3 python3-distutils      && rm -rf /var/lib/apt/lists/*
  • Dangerous shell operationline 146
    && rm -rf /var/lib/apt/lists/*
  • Dangerous shell operationline 175
    RUN apt-get update      && apt-get install -y --no-install-recommends          build-essential          libpq-dev          git      && apt-get clean      && rm -rf /var/lib/apt/lists/*
  • Dangerous shell operationline 181
    && rm -rf /var/lib/apt/lists/*
  • Network accessline 188
    # Use pip cache mount + official constraints ARG CONSTRAINTS_URL="https://raw.githubusercontent.com/apache/airflow/constraints-${AIRFLOW_VERSION}/constraints-${PYTHON_VERSION}.txt"
  • Network accessline 189
    ARG CONSTRAINTS_URL="https://raw.githubusercontent.com/apache/airflow/constraints-${AIRFLOW_VERSION}/constraints-${PYTHON_VERSION}.txt"
  • Access to secretsline 277
    [Credential-related source omitted]
  • Access to secretsline 346
    [Credential-related source omitted]
  • Access to secretsline 349
    [Credential-related source omitted]
  • Network accessline 403
    - "8080:8080"     healthcheck:       test: ["CMD", "curl", "--fail", "http://localhost:8080/health"]
  • Network accessline 404
    healthcheck:       test: ["CMD", "curl", "--fail", "http://localhost:8080/health"]       interval: 30s
  • Network accessline 405
    test: ["CMD", "curl", "--fail", "http://localhost:8080/health"]
  • Network accessline 438
    - ./spark/conf:/opt/bitnami/spark/conf:ro     healthcheck:       test: ["CMD", "curl", "--fail", "http://localhost:8080"]
  • Network accessline 439
    healthcheck:       test: ["CMD", "curl", "--fail", "http://localhost:8080"]       interval: 15s
  • Network accessline 440
    test: ["CMD", "curl", "--fail", "http://localhost:8080"]
  • Network accessline 475
    - minio-data:/data     healthcheck:       test: ["CMD", "curl", "-f", "http://localhost:9000/minio/health/live"]
  • Network accessline 476
    healthcheck:       test: ["CMD", "curl", "-f", "http://localhost:9000/minio/health/live"]       interval: 15s
  • Network accessline 477
    test: ["CMD", "curl", "-f", "http://localhost:9000/minio/health/live"]
  • Network accessline 491
    entrypoint: >       /bin/sh -c "         mc alias set local http://minio:9000 minioadmin minioadmin;
  • Network accessline 492
    /bin/sh -c "         mc alias set local http://minio:9000 minioadmin minioadmin;         mc mb --ignore-existing local/raw-data;
  • Network accessline 493
    mc alias set local http://minio:9000 minioadmin minioadmin;
  • Network accessline 555
    SCHEMA_REGISTRY_HOST_NAME: schema-registry       SCHEMA_REGISTRY_KAFKASTORE_BOOTSTRAP_SERVERS: kafka:29092       SCHEMA_REGISTRY_LISTENERS: http://0.0.0.0:8082
  • Network accessline 556
    SCHEMA_REGISTRY_KAFKASTORE_BOOTSTRAP_SERVERS: kafka:29092       SCHEMA_REGISTRY_LISTENERS: http://0.0.0.0:8082     ports:
  • Network accessline 557
    SCHEMA_REGISTRY_LISTENERS: http://0.0.0.0:8082
  • Network accessline 559
    - "8082:8082"     healthcheck:       test: ["CMD", "curl", "--fail", "http://localhost:8082/subjects"]
  • Network accessline 560
    healthcheck:       test: ["CMD", "curl", "--fail", "http://localhost:8082/subjects"]       interval: 15s
  • Network accessline 561
    test: ["CMD", "curl", "--fail", "http://localhost:8082/subjects"]
  • Access to secretsline 592
    [Credential-related source omitted]
  • Access to secretsline 593
    [Credential-related source omitted]
  • Network accessline 617
    RUN --mount=type=cache,target=/root/.cache/pip \     --mount=type=secret,id=pip_token \     PIP_INDEX_URL="https://$(cat /run/secrets/pip_token)@private.pypi.corp/simple/" \
  • Network accessline 618
    --mount=type=secret,id=pip_token \     PIP_INDEX_URL="https://$(cat /run/secrets/pip_token)@private.pypi.corp/simple/" \     pip install -r requirements.txt \
  • Network accessline 619
    PIP_INDEX_URL="https://$(cat /run/secrets/pip_token)@private.pypi.corp/simple/" \
  • Access to secretsline 628
    [Credential-related source omitted]
  • Access to secretsline 629
    [Credential-related source omitted]
  • Access to secretsline 642
    [Credential-related source omitted]
  • Access to secretsline 648
    [Credential-related source omitted]
  • Access to secretsline 649
    [Credential-related source omitted]
  • Access to secretsline 724
    [Credential-related source omitted]
  • Access to secretsline 728
    [Credential-related source omitted]
  • Access to secretsline 941
    [Credential-related source omitted]
  • Network accessline 955
    - [Docker Docs — Multi-stage builds](https://docs.docker.com/build/building/multi-stage/)
  • Network accessline 956
    - [Docker Docs — BuildKit secrets](https://docs.docker.com/build/building/secrets/)
  • Network accessline 957
    - [Docker Docs — Multi-platform builds with GitHub Actions](https://docs.docker.com/build/ci/github-actions/multi-platform/)
  • Network accessline 958
    - [Docker Docs — Base image hardening](https://docs.docker.com/dhi/core-concepts/hardening/)
  • Network accessline 959
    - [docker/build-push-action — GitHub Marketplace](https://github.com/marketplace/actions/build-and-push-docker-images)
  • Network accessline 960
    - [docker/metadata-action — GitHub Marketplace](https://github.com/marketplace/actions/docker-metadata-action)
  • Network accessline 961
    - [Sysdig — Top 21 Dockerfile best practices](https://www.sysdig.com/learn-cloud-native/dockerfile-best-practices)
  • Network accessline 962
    - [Harbor Documentation](https://goharbor.io/docs/)

skills/duckdb/SKILL.md

  • Network accessline 58
    # CLI (no Python needed) curl -fsSL https://install.duckdb.org | sh
  • Dangerous shell operationline 59
    curl -fsSL https://install.duckdb.org | sh
  • Network accessline 59
    curl -fsSL https://install.duckdb.org | sh
  • Network accessline 204
    con.sql("""     SELECT * FROM iceberg_scan(         'rest+http://iceberg-rest:8181/v1/namespaces/silver/tables/orders'
  • Network accessline 205
    SELECT * FROM iceberg_scan(         'rest+http://iceberg-rest:8181/v1/namespaces/silver/tables/orders'     )
  • Network accessline 206
    'rest+http://iceberg-rest:8181/v1/namespaces/silver/tables/orders'

skills/feature_store/SKILL.md

  • Network accessline 616
    curl -X POST http://localhost:6566/get-online-features \
  • Network accessline 956
    - Feast documentation: https://docs.feast.dev/
  • Network accessline 957
    - Feast Python SDK reference: https://rtd.feast.dev/
  • Network accessline 958
    - Feast feature repo examples: https://github.com/feast-dev/feast/tree/master/examples
  • Network accessline 959
    - Feast Redis online store setup: https://docs.feast.dev/reference/online-stores/redis
  • Network accessline 960
    - Feast Redshift offline store: https://docs.feast.dev/reference/offline-stores/redshift
  • Network accessline 961
    - Feast BigQuery offline store: https://docs.feast.dev/reference/offline-stores/bigquery
  • Network accessline 962
    - Feast PostgreSQL offline store (community): https://docs.feast.dev/reference/offline-stores/postgres
  • Network accessline 963
    - Feast streaming feature views: https://docs.feast.dev/reference/alpha-stream-ingestion
  • Network accessline 964
    - Feast push sources: https://docs.feast.dev/reference/data-sources/push
  • Network accessline 965
    - Point-in-time join explanation: https://docs.feast.dev/getting-started/concepts/point-in-time-joins
  • Network accessline 966
    - Feast on-demand feature views: https://docs.feast.dev/reference/on-demand-feature-view
  • Network accessline 967
    - Feast Airflow provider (community): https://github.com/feast-dev/feast-airflow-provider

skills/github_actions_dataops/SKILL.md

  • Network accessline 500
    AIRFLOW_VERSION=${{ matrix.airflow-version }}           PYTHON_VERSION=$(python -c "import sys; print(f'{sys.version_info.major}.{sys.version_info.minor}')")           CONSTRAINT_URL="https://raw.githubusercontent.com/apache/airflow/constra
  • Network accessline 501
    PYTHON_VERSION=$(python -c "import sys; print(f'{sys.version_info.major}.{sys.version_info.minor}')")           CONSTRAINT_URL="https://raw.githubusercontent.com/apache/airflow/constraints-${AIRFLOW_VERSION}/constraints-${PYTHON_VERSION}.tx
  • Network accessline 502
    CONSTRAINT_URL="https://raw.githubusercontent.com/apache/airflow/constraints-${AIRFLOW_VERSION}/constraints-${PYTHON_VERSION}.txt"
  • Access to secretsline 627
    [Credential-related source omitted]
  • Network accessline 695
    # Download Spark (cached as long as ARG doesn't change) RUN apt-get update && apt-get install -y curl && \
  • Network accessline 696
    RUN apt-get update && apt-get install -y curl && \
  • Network accessline 697
    curl -fsSL \
  • Network accessline 698
    "https://downloads.apache.org/spark/spark-${SPARK_VERSION}/spark-${SPARK_VERSION}-bin-hadoop${HADOOP_VERSION}.tgz" \
  • Network accessline 1272
    - [GitHub Actions: Workflow syntax](https://docs.github.com/en/actions/using-workflows/workflow-syntax-for-github-actions)
  • Network accessline 1273
    - [GitHub Actions: Reusing workflows](https://docs.github.com/en/actions/using-workflows/reusing-workflows)
  • Network accessline 1274
    - [GitHub Actions: Security hardening](https://docs.github.com/en/actions/security-guides/security-hardening-for-github-actions)
  • Network accessline 1275
    - [GitHub Actions: OIDC token](https://docs.github.com/en/actions/deployment/security-hardening-your-deployments/about-security-hardening-with-openid-connect)
  • Network accessline 1276
    - [aws-actions/configure-aws-credentials](https://github.com/aws-actions/configure-aws-credentials)
  • Network accessline 1277
    - [google-github-actions/auth](https://github.com/google-github-actions/auth)
  • Network accessline 1278
    - [docker/build-push-action](https://github.com/docker/build-push-action)
  • Network accessline 1279
    - [Docker: Cache management with GitHub Actions](https://docs.docker.com/build/ci/github-actions/cache/)
  • Network accessline 1280
    - [dbt: Slim CI](https://docs.getdbt.com/docs/deploy/slim-ci-cd)
  • Network accessline 1281
    - [dbt: Node selection — state](https://docs.getdbt.com/reference/node-selection/methods#the-state-method)
  • Network accessline 1282
    - [SQLFluff: GitHub Actions annotations](https://docs.sqlfluff.com/en/stable/production/github_actions.html)
  • Network accessline 1283
    - [sqlfluff/sqlfluff-github-actions](https://github.com/sqlfluff/sqlfluff-github-actions)
  • Network accessline 1284
    - [Soda: GitHub Action](https://github.com/sodadata/soda-github-action)
  • Network accessline 1285
    - [Great Expectations: GitHub Action](https://github.com/great-expectations/great_expectations_action)
  • Network accessline 1286
    - [Airflow: DAG testing guide (Astronomer)](https://github.com/astronomer/airflow-testing-guide)

skills/great_expectations/SKILL.md

  • Network accessline 345
    gx.checkpoint.SlackNotificationAction(                 name="slack_on_fail",                 slack_webhook="https://hooks.slack.com/services/...",
  • Network accessline 346
    name="slack_on_fail",                 slack_webhook="https://hooks.slack.com/services/...",                 notify_on="failure",
  • Network accessline 347
    slack_webhook="https://hooks.slack.com/services/...",
  • Network accessline 600
    - [Great Expectations Documentation](https://docs.greatexpectations.io/)
  • Network accessline 601
    - [GX Core Quickstart](https://docs.greatexpectations.io/docs/core/introduction/try_gx)
  • Network accessline 602
    - [Expectations Gallery](https://greatexpectations.io/expectations/)
  • Network accessline 603
    - [GX Airflow Integration](https://docs.greatexpectations.io/docs/oss/integrations/integration_airflow)
  • Network accessline 604
    - [dbt-expectations package](https://github.com/calogica/dbt-expectations)

skills/kubernetes_data/SKILL.md

  • Network accessline 116
    spark-submit \   --master k8s://https://$(kubectl config view --minify -o jsonpath='{.clusters[0].cluster.server}' | sed 's|https://||') \
  • Network accessline 117
    --master k8s://https://$(kubectl config view --minify -o jsonpath='{.clusters[0].cluster.server}' | sed 's|https://||') \
  • Network accessline 223
    spark-submit \   --master k8s://https://k8s-api:6443 \
  • Network accessline 224
    --master k8s://https://k8s-api:6443 \
  • Network accessline 272
    -Dspark.history.fs.logDirectory=s3a://data-lake/spark-history                 -Dspark.history.ui.port=18080                 -Dspark.hadoop.fs.s3a.endpoint=http://minio:9000
  • Network accessline 273
    -Dspark.history.ui.port=18080                 -Dspark.hadoop.fs.s3a.endpoint=http://minio:9000                 -Dspark.hadoop.fs.s3a.access.key=minioadmin
  • Network accessline 274
    -Dspark.hadoop.fs.s3a.endpoint=http://minio:9000
  • Network accessline 301
    # Add Airflow Helm repo helm repo add apache-airflow https://airflow.apache.org
  • Network accessline 302
    helm repo add apache-airflow https://airflow.apache.org
  • Network accessline 389
    gitSync:     enabled: true     repo: https://github.com/org/airflow-dags.git
  • Network accessline 390
    enabled: true     repo: https://github.com/org/airflow-dags.git     branch: main
  • Network accessline 391
    repo: https://github.com/org/airflow-dags.git
  • Access to secretsline 396
    [Credential-related source omitted]
  • Network accessline 439
    env:     - name: AIRFLOW__OPENLINEAGE__TRANSPORT       value: '{"type": "http", "url": "http://marquez.lineage:5000", "endpoint": "api/v1/lineage"}'
  • Network accessline 440
    - name: AIRFLOW__OPENLINEAGE__TRANSPORT       value: '{"type": "http", "url": "http://marquez.lineage:5000", "endpoint": "api/v1/lineage"}'     - name: AIRFLOW__OPENLINEAGE__NAMESPACE
  • Network accessline 441
    value: '{"type": "http", "url": "http://marquez.lineage:5000", "endpoint": "api/v1/lineage"}'
  • Network accessline 471
    arguments=["/opt/spark/jobs/transform_orders.py"],     env_vars={         "SPARK_MASTER": "k8s://https://k8s-api:6443",
  • Network accessline 472
    env_vars={         "SPARK_MASTER": "k8s://https://k8s-api:6443",         "WAREHOUSE_URI": "s3a://data-lake/warehouse",
  • Network accessline 473
    "SPARK_MASTER": "k8s://https://k8s-api:6443",
  • Network accessline 513
    application="s3a://data-lake/jobs/silver_etl.py",     name="silver-etl-{{ ds_nodash }}",     conn_id="spark_k8s",               # Connection: master = k8s://https://...
  • Network accessline 514
    name="silver-etl-{{ ds_nodash }}",     conn_id="spark_k8s",               # Connection: master = k8s://https://...     deploy_mode="cluster",
  • Network accessline 515
    conn_id="spark_k8s",               # Connection: master = k8s://https://...
  • Network accessline 524
    "spark.kubernetes.container.image": "registry.local/spark:3.5.1-custom",         "spark.openlineage.transport.type": "http",         "spark.openlineage.transport.url": "http://marquez.lineage:5000",
  • Network accessline 525
    "spark.openlineage.transport.type": "http",         "spark.openlineage.transport.url": "http://marquez.lineage:5000",         "spark.openlineage.namespace": "spark://k8s",
  • Network accessline 526
    "spark.openlineage.transport.url": "http://marquez.lineage:5000",
  • Network accessline 585
    [Credential-related source omitted]
  • Network accessline 586
    [Credential-related source omitted]
  • Access to secretsline 586
    [Credential-related source omitted]
  • Network accessline 587
    [Credential-related source omitted]
  • Access to secretsline 587
    [Credential-related source omitted]

skills/mage_ai/SKILL.md

  • Access to secretsline 110
    [Credential-related source omitted]
  • Access to secretsline 117
    [Credential-related source omitted]
  • Access to secretsline 127
    [Credential-related source omitted]
  • Access to secretsline 138
    [Credential-related source omitted]
  • Access to secretsline 143
    [Credential-related source omitted]
  • Network accessline 454
    spark_config:   app_name: orders_daily_etl   spark_master: "k8s://https://k8s.prod.internal:443"
  • Network accessline 455
    app_name: orders_daily_etl   spark_master: "k8s://https://k8s.prod.internal:443"   executor_instances: 4
  • Network accessline 456
    spark_master: "k8s://https://k8s.prod.internal:443"
  • Network accessline 580
    curl -X POST http://localhost:6789/api/pipeline_runs \
  • Network accessline 598
    curl -X POST http://localhost:6789/api/pipelines/orders_daily_etl/backfills \
  • Network accessline 727
    spark_config:   app_name:           orders_spark_etl   spark_master:       "k8s://https://k8s.prod.internal:443"
  • Network accessline 728
    app_name:           orders_spark_etl   spark_master:       "k8s://https://k8s.prod.internal:443"   executor_instances: 8
  • Network accessline 729
    spark_master:       "k8s://https://k8s.prod.internal:443"
  • Network accessline 831
    [Credential-related source omitted]
  • Access to secretsline 831
    [Credential-related source omitted]
  • Network accessline 832
    [Credential-related source omitted]
  • Access to secretsline 832
    [Credential-related source omitted]
  • Network accessline 833
    'schema_registry_url': 'https://schema-registry.prod.internal',
  • Access to secretsline 942
    [Credential-related source omitted]
  • Network accessline 954
    }     data = json.dumps(message).encode()     urllib.request.urlopen(
  • Network accessline 955
    data = json.dumps(message).encode()     urllib.request.urlopen(         urllib.request.Request(webhook_url, data=data,
  • Network accessline 956
    urllib.request.urlopen(
  • Network accessline 957
    urllib.request.Request(webhook_url, data=data,
  • Access to secretsline 1031
    [Credential-related source omitted]

skills/mcp_server/SKILL.md

  • Network accessline 269
    "data-platform-remote": {       "type": "http",       "url": "https://platform-mcp.internal/mcp"
  • Network accessline 270
    "type": "http",       "url": "https://platform-mcp.internal/mcp"     }
  • Network accessline 271
    "url": "https://platform-mcp.internal/mcp"
  • Network accessline 290
    # Test HTTP server npx @modelcontextprotocol/inspector --transport http --url http://localhost:8080/mcp
  • Network accessline 291
    npx @modelcontextprotocol/inspector --transport http --url http://localhost:8080/mcp
  • Access to secretsline 389
    [Credential-related source omitted]
  • Access to secretsline 390
    [Credential-related source omitted]
  • Access to secretsline 465
    [Credential-related source omitted]
  • Access to secretsline 466
    [Credential-related source omitted]
  • Access to secretsline 467
    [Credential-related source omitted]
  • Access to secretsline 549
    [Credential-related source omitted]

skills/mlflow_pipelines/SKILL.md

  • Network accessline 44
    export MLFLOW_TRACKING_URI="http://mlflow-server:5000"
  • Access to secretsline 78
    [Credential-related source omitted]
  • Network accessline 119
    MLFLOW_TRACKING_URI = "http://mlflow-server:5000"
  • Network accessline 221
    MLFLOW_TRACKING_URI = "http://mlflow-server:5000"
  • Network accessline 324
    client = MlflowClient(tracking_uri="http://mlflow-server:5000")
  • Network accessline 420
    # Score a single record curl -s http://localhost:8080/invocations \
  • Network accessline 421
    curl -s http://localhost:8080/invocations \
  • Network accessline 425
    # Score with split orientation curl -s http://localhost:8080/invocations \
  • Network accessline 426
    curl -s http://localhost:8080/invocations \
  • Network accessline 548
    # Remote Git repo run mlflow run https://github.com/myorg/churn-model.git \
  • Network accessline 549
    mlflow run https://github.com/myorg/churn-model.git \
  • Network accessline 573
    TRACKING_URI = "http://mlflow-server:5000"
  • Network accessline 655
    # Airflow Connection: mlflow_default #   conn_type: HTTP #   host: http://mlflow-server
  • Network accessline 656
    #   conn_type: HTTP #   host: http://mlflow-server #   port: 5000
  • Network accessline 657
    #   host: http://mlflow-server
  • Network accessline 674
    mlflow.set_tracking_uri("http://mlflow-server:5000")
  • Network accessline 788
    - MLflow Tracking Server docs: https://mlflow.org/docs/latest/ml/tracking/tutorials/remote-server/
  • Network accessline 789
    - MLflow Model Registry workflows: https://mlflow.org/docs/latest/ml/model-registry/workflow/
  • Network accessline 790
    - MLflow PyFunc API: https://mlflow.org/docs/latest/python_api/mlflow.pyfunc.html
  • Network accessline 791
    - MLflow Spark integration: https://mlflow.org/docs/latest/ml/traditional-ml/sparkml/
  • Network accessline 792
    - MLflow Projects: https://mlflow.org/docs/latest/projects/
  • Network accessline 793
    - Airflow + MLflow guide (Astronomer): https://www.astronomer.io/docs/learn/2.x/airflow-mlflow
  • Network accessline 794
    - Model aliases RFC (deprecating stages): https://github.com/mlflow/mlflow/issues/10336

skills/openlineage/SKILL.md

  • Network accessline 51
    "eventType": "COMPLETE",   "eventTime": "2024-03-15T10:30:00.000Z",   "producer": "https://github.com/OpenLineage/OpenLineage/tree/1.0.0/integration/spark",
  • Network accessline 52
    "eventTime": "2024-03-15T10:30:00.000Z",   "producer": "https://github.com/OpenLineage/OpenLineage/tree/1.0.0/integration/spark",   "schemaURL": "https://openlineage.io/spec/1-0-5/OpenLineage.json#/definitions/RunEvent",
  • Network accessline 53
    "producer": "https://github.com/OpenLineage/OpenLineage/tree/1.0.0/integration/spark",
  • Network accessline 54
    "schemaURL": "https://openlineage.io/spec/1-0-5/OpenLineage.json#/definitions/RunEvent",
  • Network accessline 85
    "_schemaURL": "...",         "type": "git",         "url": "https://github.com/org/repo",
  • Network accessline 86
    "type": "git",         "url": "https://github.com/org/repo",         "repoUrl": "https://github.com/org/repo",
  • Network accessline 87
    "url": "https://github.com/org/repo",
  • Network accessline 88
    "repoUrl": "https://github.com/org/repo",
  • Network accessline 269
    # List namespaces curl http://localhost:5000/api/v1/namespaces | jq
  • Network accessline 270
    curl http://localhost:5000/api/v1/namespaces | jq
  • Network accessline 272
    # List jobs in namespace curl "http://localhost:5000/api/v1/namespaces/airflow/jobs" | jq
  • Network accessline 273
    curl "http://localhost:5000/api/v1/namespaces/airflow/jobs" | jq
  • Network accessline 275
    # Get dataset with lineage curl "http://localhost:5000/api/v1/namespaces/spark://master:7077/datasets/silver.orders" | jq
  • Network accessline 276
    curl "http://localhost:5000/api/v1/namespaces/spark://master:7077/datasets/silver.orders" | jq
  • Network accessline 278
    # Get lineage graph (upstream + downstream, depth=2) curl "http://localhost:5000/api/v1/lineage?nodeId=dataset:spark://master:7077:silver.orders&depth=2" | jq
  • Network accessline 279
    curl "http://localhost:5000/api/v1/lineage?nodeId=dataset:spark://master:7077:silver.orders&depth=2" | jq
  • Network accessline 281
    # Search datasets curl "http://localhost:5000/api/v1/search?q=orders&type=DATASET" | jq
  • Network accessline 282
    curl "http://localhost:5000/api/v1/search?q=orders&type=DATASET" | jq
  • Network accessline 298
    [openlineage] transport = {"type": "http", "url": "http://marquez:5000", "endpoint": "api/v1/lineage"}
  • Network accessline 299
    transport = {"type": "http", "url": "http://marquez:5000", "endpoint": "api/v1/lineage"}
  • Network accessline 308
    export OPENLINEAGE_URL=http://marquez:5000
  • Network accessline 310
    export AIRFLOW__OPENLINEAGE__TRANSPORT='{"type": "http", "url": "http://marquez:5000", "endpoint": "api/v1/lineage"}'
  • Network accessline 374
    # Download JAR for spark-submit wget https://repo1.maven.org/maven2/io/openlineage/openlineage-spark_2.12/1.15.0/openlineage-spark_2.12-1.15.0.jar
  • Network accessline 375
    wget https://repo1.maven.org/maven2/io/openlineage/openlineage-spark_2.12/1.15.0/openlineage-spark_2.12-1.15.0.jar
  • Network accessline 381
    spark-submit    --jars /opt/spark/jars/openlineage-spark_2.12-1.15.0.jar    --conf spark.extraListeners=io.openlineage.spark.agent.OpenLineageSparkListener    --conf spark.openlineage.transport.type=http    --conf spark.openlineage.transpor
  • Network accessline 383
    --conf spark.extraListeners=io.openlineage.spark.agent.OpenLineageSparkListener \   --conf spark.openlineage.transport.type=http \   --conf spark.openlineage.transport.url=http://marquez:5000 \
  • Network accessline 384
    --conf spark.openlineage.transport.type=http \   --conf spark.openlineage.transport.url=http://marquez:5000 \   --conf spark.openlineage.transport.endpoint=/api/v1/lineage \
  • Network accessline 385
    --conf spark.openlineage.transport.url=http://marquez:5000 \
  • Network accessline 402
    "io.openlineage.spark.agent.OpenLineageSparkListener") \     .config("spark.openlineage.transport.type", "http") \     .config("spark.openlineage.transport.url", "http://marquez:5000") \
  • Network accessline 403
    .config("spark.openlineage.transport.type", "http") \     .config("spark.openlineage.transport.url", "http://marquez:5000") \     .config("spark.openlineage.transport.endpoint", "/api/v1/lineage") \
  • Network accessline 404
    .config("spark.openlineage.transport.url", "http://marquez:5000") \
  • Network accessline 438
    # Run dbt with OpenLineage emission export OPENLINEAGE_URL=http://marquez:5000
  • Network accessline 439
    export OPENLINEAGE_URL=http://marquez:5000
  • Network accessline 489
    client = OpenLineageClient(     transport=HttpTransport(         HttpConfig(url="http://marquez:5000", endpoint="api/v1/lineage")
  • Network accessline 490
    transport=HttpTransport(         HttpConfig(url="http://marquez:5000", endpoint="api/v1/lineage")     )
  • Network accessline 491
    HttpConfig(url="http://marquez:5000", endpoint="api/v1/lineage")
  • Network accessline 502
    run=Run(runId=run_id),     job=Job(namespace="my-pipeline", name="daily_revenue"),     producer="https://github.com/org/pipeline",
  • Network accessline 503
    job=Job(namespace="my-pipeline", name="daily_revenue"),     producer="https://github.com/org/pipeline",     inputs=[InputDataset(namespace="postgres://db:5432", name="public.orders")],
  • Network accessline 504
    producer="https://github.com/org/pipeline",
  • Network accessline 519
    facets={"sql": SqlJobFacet(query="SELECT order_date, SUM(total) AS revenue FROM orders GROUP BY 1")},     ),     producer="https://github.com/org/pipeline",
  • Network accessline 520
    ),     producer="https://github.com/org/pipeline",     inputs=[
  • Network accessline 521
    producer="https://github.com/org/pipeline",
  • Network accessline 608
    transport = CompositeTransport(CompositeConfig(transports=[     {"type": "http", "url": "http://marquez:5000", "endpoint": "api/v1/lineage"},
  • Network accessline 609
    {"type": "http", "url": "http://marquez:5000", "endpoint": "api/v1/lineage"},
  • Network accessline 623
    def get_downstream_jobs(namespace: str, dataset_name: str, depth: int = 5) -> list[dict]:     """Return all jobs that read from the given dataset (transitively)."""     resp = requests.get(
  • Network accessline 624
    """Return all jobs that read from the given dataset (transitively)."""     resp = requests.get(         "http://marquez:5000/api/v1/lineage",
  • Network accessline 625
    resp = requests.get(
  • Network accessline 626
    "http://marquez:5000/api/v1/lineage",

skills/postgresql_de/SKILL.md

  • Network accessline 891
    - [PostgreSQL 16 Documentation — Table Partitioning](https://www.postgresql.org/docs/16/ddl-partitioning.html)
  • Network accessline 892
    - [PostgreSQL 16 Documentation — EXPLAIN](https://www.postgresql.org/docs/16/sql-explain.html)
  • Network accessline 893
    - [PostgreSQL 16 Documentation — Populating a Database (bulk load)](https://www.postgresql.org/docs/16/populate.html)
  • Network accessline 894
    - [PostgreSQL 16 Documentation — Index Types](https://www.postgresql.org/docs/16/indexes-types.html)
  • Network accessline 895
    - [PostgreSQL 16 Documentation — WITH Queries](https://www.postgresql.org/docs/16/queries-with.html)
  • Network accessline 896
    - [PostgreSQL 16 Documentation — JSON Types](https://www.postgresql.org/docs/16/datatype-json.html)
  • Network accessline 897
    - [PostgreSQL 16 Documentation — Autovacuum](https://www.postgresql.org/docs/16/routine-vacuuming.html)
  • Network accessline 898
    - [pg_partman GitHub](https://github.com/pgpartman/pg_partman) — partition management extension
  • Network accessline 899
    - [pganalyze — Understanding GIN Indexes](https://pganalyze.com/blog/gin-index)
  • Network accessline 900
    - [EDB — 7 Best Practice Tips for PostgreSQL Bulk Data Loading](https://www.enterprisedb.com/blog/7-best-practice-tips-postgresql-bulk-data-loading)
  • Network accessline 901
    - [Cybertec — PostgreSQL Bulk Loading](https://www.cybertec-postgresql.com/en/postgresql-bulk-loading-huge-amounts-of-data/)
  • Network accessline 902
    - [Percona — Tuning Autovacuum in PostgreSQL](https://www.percona.com/blog/tuning-autovacuum-in-postgresql-and-autovacuum-internals/)
  • Network accessline 903
    - [Crunchy Data — Indexing JSONB in Postgres](https://www.crunchydata.com/blog/indexing-jsonb-in-postgres)

skills/prefect_workflows/SKILL.md

  • Network accessline 49
    prefect server start          # UI at http://127.0.0.1:4200
  • Network accessline 55
    prefect cloud login --key pnu_XXXX        # paste API key prefect config set PREFECT_API_URL="https://api.prefect.cloud/api/accounts/.../workspaces/..."
  • Network accessline 56
    prefect config set PREFECT_API_URL="https://api.prefect.cloud/api/accounts/.../workspaces/..."
  • Access to secretsline 169
    [Credential-related source omitted]
  • Network accessline 185
    """Expensive API call; cache result for 6 hours per input combo."""     import httpx     resp = httpx.get(
  • Network accessline 186
    import httpx     resp = httpx.get(         f"https://api.exchangerate-api.com/v4/latest/{base_currency}",
  • Network accessline 187
    resp = httpx.get(
  • Network accessline 188
    f"https://api.exchangerate-api.com/v4/latest/{base_currency}",
  • Network accessline 322
    """Called when the flow transitions to Failed state."""     error = state.result(raise_on_failure=False)     httpx.post(
  • Network accessline 323
    error = state.result(raise_on_failure=False)     httpx.post(         "https://hooks.slack.com/services/XXX/YYY/ZZZ",
  • Network accessline 324
    httpx.post(
  • Network accessline 325
    "https://hooks.slack.com/services/XXX/YYY/ZZZ",
  • Network accessline 336
    def on_flow_completion(flow, flow_run, state):     result = state.result()     httpx.post(
  • Network accessline 337
    result = state.result()     httpx.post(         "https://hooks.slack.com/services/XXX/YYY/ZZZ",
  • Network accessline 338
    httpx.post(
  • Network accessline 339
    "https://hooks.slack.com/services/XXX/YYY/ZZZ",
  • Network accessline 748
    id: clone-repo       requires: prefect>=3.0.0       repository: https://github.com/my-org/data-platform.git
  • Network accessline 749
    requires: prefect>=3.0.0       repository: https://github.com/my-org/data-platform.git       branch: main
  • Network accessline 750
    repository: https://github.com/my-org/data-platform.git
  • Access to secretsline 752
    [Credential-related source omitted]
  • Network accessline 948
    create_link_artifact(         key="report-link",         link=f"https://s3.console.aws.amazon.com/s3/object/data-lake/{s3_key}",
  • Network accessline 949
    key="report-link",         link=f"https://s3.console.aws.amazon.com/s3/object/data-lake/{s3_key}",         description="Full profiling report on S3",
  • Network accessline 950
    link=f"https://s3.console.aws.amazon.com/s3/object/data-lake/{s3_key}",
  • Access to secretsline 1194
    [Credential-related source omitted]

skills/pyspark_etl/SKILL.md

  • Network accessline 263
    - Apache Spark SQL Performance Tuning: https://spark.apache.org/docs/latest/sql-performance-tuning.html
  • Network accessline 264
    - PySpark Arrow and pandas UDF guide: https://spark.apache.org/docs/3.5.5/api/python/user_guide/sql/arrow_pandas.html
  • Network accessline 265
    - PySpark API docs for pandas UDFs: https://spark.apache.org/docs/latest/api/python/reference/pyspark.sql/api/pyspark.sql.functions.pandas_udf.html

skills/pyspark_streaming/SKILL.md

  • Network accessline 668
    - [Spark Structured Streaming Guide](https://spark.apache.org/docs/latest/structured-streaming-programming-guide.html)
  • Network accessline 669
    - [Spark + Kafka Integration](https://spark.apache.org/docs/latest/streaming/structured-streaming-kafka-integration.html)
  • Network accessline 670
    - [Databricks Watermarking Deep Dive](https://www.databricks.com/blog/2022/08/22/feature-deep-dive-watermarking-apache-spark-structured-streaming.html)
  • Network accessline 671
    - [Delta Lake Streaming](https://docs.delta.io/latest/delta-streaming.html)

skills/rag_pipeline/SKILL.md

  • Access to secretsline 210
    [Credential-related source omitted]
  • Access to secretsline 245
    [Credential-related source omitted]
  • Network accessline 432
    [Credential-related source omitted]
  • Access to secretsline 432
    [Credential-related source omitted]
  • Access to secretsline 624
    [Credential-related source omitted]
  • Access to secretsline 632
    [Credential-related source omitted]
  • Access to secretsline 634
    [Credential-related source omitted]
  • Network accessline 948
    - pgvector HNSW tuning: https://github.com/pgvector/pgvector — `ef_construction`, `m`, `iterative_scan`
  • Network accessline 949
    - Qdrant filtering docs: https://qdrant.tech/documentation/concepts/filtering/
  • Network accessline 950
    - LangChain text splitters: https://python.langchain.com/docs/modules/data_connection/document_transformers/
  • Network accessline 951
    - OpenAI embeddings: https://platform.openai.com/docs/guides/embeddings
  • Network accessline 952
    - Cohere Rerank API: https://docs.cohere.com/reference/rerank
  • Network accessline 953
    - sentence-transformers cross-encoders: https://www.sbert.net/docs/pretrained_cross-encoders.html
  • Network accessline 954
    - BM25 Python: https://github.com/dorianbrown/rank_bm25

skills/ray_data/SKILL.md

  • Network accessline 594
    ray.data.read_parquet("s3://my-bucket/raw/events/dt=2026-05-17/").write_datasink(     IcebergDatasink("https://iceberg-rest.internal:8181", "analytics", "events")
  • Network accessline 595
    IcebergDatasink("https://iceberg-rest.internal:8181", "analytics", "events")
  • Network accessline 940
    - Ray Data User Guide: https://docs.ray.io/en/latest/data/data.html
  • Network accessline 941
    - Ray Data API Reference: https://docs.ray.io/en/latest/data/api/api.html
  • Network accessline 942
    - KubeRay Operator docs: https://ray-project.github.io/kuberay/
  • Network accessline 943
    - Ray Jobs API: https://docs.ray.io/en/latest/cluster/running-applications/job-submission/index.html
  • Network accessline 944
    - Ray Cluster on EC2 (ray up): https://docs.ray.io/en/latest/cluster/vms/getting-started.html
  • Network accessline 945
    - Ray Autoscaler configuration: https://docs.ray.io/en/latest/cluster/vms/references/ray-cluster-configuration.html
  • Network accessline 946
    - Airflow Ray provider (SubmitRayJob): https://astronomer.github.io/astronomer-providers/ray/
  • Network accessline 947
    - PyIceberg write API: https://py.iceberg.apache.org/api/

skills/redpanda/SKILL.md

  • Network accessline 127
    schemaRegistry:     enabled: true     urls: ["http://redpanda:8081"]
  • Network accessline 128
    enabled: true     urls: ["http://redpanda:8081"] redpanda:
  • Network accessline 129
    urls: ["http://redpanda:8081"]
  • Network accessline 131
    adminApi:     enabled: true     urls: ["http://redpanda:9644"]
  • Network accessline 133
    urls: ["http://redpanda:9644"]
  • Network accessline 237
    schemaRegistry:     enabled: true     urls: ["http://redpanda-0:8081"]
  • Network accessline 238
    enabled: true     urls: ["http://redpanda-0:8081"] redpanda:
  • Network accessline 239
    urls: ["http://redpanda-0:8081"]
  • Network accessline 242
    enabled: true     urls:       - "http://redpanda-0:9644"
  • Network accessline 243
    urls:       - "http://redpanda-0:9644"       - "http://redpanda-1:9644"
  • Network accessline 244
    - "http://redpanda-0:9644"
  • Network accessline 245
    - "http://redpanda-1:9644"
  • Network accessline 246
    - "http://redpanda-2:9644"
  • Network accessline 256
    helm repo add redpanda https://charts.redpanda.com
  • Network accessline 851
    # Register an Avro schema curl -X POST http://localhost:18081/subjects/orders-value/versions \
  • Network accessline 852
    curl -X POST http://localhost:18081/subjects/orders-value/versions \
  • Network accessline 858
    # Get schema by subject and version curl http://localhost:18081/subjects/orders-value/versions/latest
  • Network accessline 859
    curl http://localhost:18081/subjects/orders-value/versions/latest
  • Network accessline 861
    # List all subjects curl http://localhost:18081/subjects
  • Network accessline 862
    curl http://localhost:18081/subjects
  • Network accessline 864
    # Check compatibility before registering curl -X POST http://localhost:18081/compatibility/subjects/orders-value/versions/latest \
  • Network accessline 865
    curl -X POST http://localhost:18081/compatibility/subjects/orders-value/versions/latest \
  • Network accessline 869
    # Set compatibility mode per subject curl -X PUT http://localhost:18081/config/orders-value \
  • Network accessline 870
    curl -X PUT http://localhost:18081/config/orders-value \
  • Network accessline 895
    # Schema Registry client pointing to Redpanda's built-in SR schema_registry_client = SchemaRegistryClient({     "url": "http://localhost:18081",
  • Network accessline 896
    schema_registry_client = SchemaRegistryClient({     "url": "http://localhost:18081", })
  • Network accessline 897
    "url": "http://localhost:18081",
  • Network accessline 997
    key.converter=org.apache.kafka.connect.json.JsonConverter value.converter=io.confluent.connect.avro.AvroConverter value.converter.schema.registry.url=http://redpanda-0:8081
  • Network accessline 999
    value.converter.schema.registry.url=http://redpanda-0:8081
  • Network accessline 1541
    - [Redpanda Documentation](https://docs.redpanda.com/)
  • Network accessline 1542
    - [rpk CLI Reference](https://docs.redpanda.com/current/reference/rpk/)
  • Network accessline 1543
    - [Redpanda Helm Chart Values Reference](https://docs.redpanda.com/current/deploy/deployment-option/self-hosted/kubernetes/kubernetes-deploy/)
  • Network accessline 1544
    - [Redpanda Operator (CRD)](https://docs.redpanda.com/current/deploy/deployment-option/self-hosted/kubernetes/k-operator/)
  • Network accessline 1545
    - [Shadow Indexing / Tiered Storage](https://docs.redpanda.com/current/manage/tiered-storage/)
  • Network accessline 1546
    - [Redpanda Schema Registry API](https://docs.redpanda.com/current/develop/http-proxy/)
  • Network accessline 1547
    - [Redpanda Monitoring Reference](https://docs.redpanda.com/current/manage/monitoring/)
  • Network accessline 1548
    - [Redpanda Security: SASL, mTLS, ACLs](https://docs.redpanda.com/current/manage/security/)
  • Network accessline 1549
    - [MirrorMaker 2 with Redpanda](https://docs.redpanda.com/current/migrate/kafka-migrate/)
  • Network accessline 1550
    - [confluent-kafka Python client](https://docs.confluent.io/platform/current/clients/confluent-kafka-python/html/index.html)
  • Network accessline 1551
    - [aiokafka documentation](https://aiokafka.readthedocs.io/)

skills/soda_core/SKILL.md

  • Network accessline 118
    account_info_json: ${BIGQUERY_CREDENTIALS}   auth_scopes:     - https://www.googleapis.com/auth/bigquery
  • Network accessline 119
    auth_scopes:     - https://www.googleapis.com/auth/bigquery   project_id: my-gcp-project
  • Network accessline 120
    - https://www.googleapis.com/auth/bigquery
  • Access to secretsline 336
    [Credential-related source omitted]
  • Access to secretsline 338
    [Credential-related source omitted]
  • Access to secretsline 425
    [Credential-related source omitted]
  • Access to secretsline 426
    [Credential-related source omitted]
  • Access to secretsline 427
    [Credential-related source omitted]

skills/spark_sql/SKILL.md

  • Network accessline 491
    - Local HDFS/Hive operations reference: `/docs/specs/spark_sql_hdfs_hive_operations.md` - Apache Spark SQL Performance Tuning: https://spark.apache.org/docs/latest/sql-performance-tuning.html
  • Network accessline 492
    - Apache Spark SQL Performance Tuning: https://spark.apache.org/docs/latest/sql-performance-tuning.html
  • Network accessline 493
    - Apache Spark SQL Syntax: https://spark.apache.org/docs/latest/sql-ref-syntax.html
  • Network accessline 494
    - Apache Spark SQL Hints: https://spark.apache.org/docs/latest/sql-ref-syntax-qry-select-hints.html
  • Network accessline 495
    - Apache Spark SQL EXPLAIN: https://spark.apache.org/docs/latest/sql-ref-syntax-qry-explain.html
  • Network accessline 496
    - Apache Spark SQL ANALYZE TABLE: https://spark.apache.org/docs/latest/sql-ref-syntax-aux-analyze-table.html

skills/sqlfluff/SKILL.md

  • Network accessline 780
    # .pre-commit-config.yaml repos:   - repo: https://github.com/sqlfluff/sqlfluff
  • Network accessline 781
    repos:   - repo: https://github.com/sqlfluff/sqlfluff     rev: 3.3.0          # pin to a specific release tag
  • Network accessline 782
    - repo: https://github.com/sqlfluff/sqlfluff
  • Network accessline 819
    # Lightweight pre-commit config using jinja templater (no dbt dep required) repos:   - repo: https://github.com/sqlfluff/sqlfluff
  • Network accessline 820
    repos:   - repo: https://github.com/sqlfluff/sqlfluff     rev: 3.3.0
  • Network accessline 821
    - repo: https://github.com/sqlfluff/sqlfluff
  • Dangerous shell operationline 1412
    find . -name ".sqlfluff_cache" -type d -exec rm -rf {} +
  • Network accessline 1466
    - [SQLFluff Documentation](https://docs.sqlfluff.com/en/stable/)
  • Network accessline 1467
    - [SQLFluff Rule Reference](https://docs.sqlfluff.com/en/stable/reference/rules.html)
  • Network accessline 1468
    - [SQLFluff Configuration Reference](https://docs.sqlfluff.com/en/stable/reference/configuration.html)
  • Network accessline 1469
    - [SQLFluff: dbt Templater](https://docs.sqlfluff.com/en/stable/reference/templating.html#dbt-project-configuration)
  • Network accessline 1470
    - [SQLFluff: Custom Rules](https://docs.sqlfluff.com/en/stable/guides/custom_rules.html)
  • Network accessline 1471
    - [SQLFluff: GitHub Actions](https://docs.sqlfluff.com/en/stable/production/github_actions.html)
  • Network accessline 1472
    - [SQLFluff: Pre-commit hooks](https://docs.sqlfluff.com/en/stable/production/pre_commit.html)
  • Network accessline 1473
    - [SQLFluff GitHub](https://github.com/sqlfluff/sqlfluff)
  • Network accessline 1474
    - [sqlfluff-templater-dbt on PyPI](https://pypi.org/project/sqlfluff-templater-dbt/)
  • Network accessline 1475
    - [dbt: Docs on SQLFluff integration](https://docs.getdbt.com/docs/core/connect-data-platform/connection-profiles)
  • Network accessline 1476
    - [pre-commit: SQLFluff hooks](https://github.com/sqlfluff/sqlfluff/blob/main/.pre-commit-hooks.yaml)
  • Network accessline 1477
    - [stefanzweifel/git-auto-commit-action](https://github.com/stefanzweifel/git-auto-commit-action)

skills/sqlmesh/SKILL.md

  • Network accessline 99
    type: spark       config:         spark.master: k8s://https://k8s-api:6443
  • Network accessline 100
    config:         spark.master: k8s://https://k8s-api:6443         spark.kubernetes.container.image: registry.local/spark:3.5.1
  • Network accessline 101
    spark.master: k8s://https://k8s-api:6443

skills/terraform_data/SKILL.md

  • Access to secretsline 696
    [Credential-related source omitted]
  • Access to secretsline 727
    [Credential-related source omitted]
  • Network accessline 799
    resource "helm_release" "airflow" {   name             = "airflow"   repository       = "https://airflow.apache.org"
  • Network accessline 800
    name             = "airflow"   repository       = "https://airflow.apache.org"   chart            = "airflow"
  • Network accessline 801
    repository       = "https://airflow.apache.org"
  • Network accessline 836
    resource "helm_release" "spark_history_server" {   name             = "spark-history-server"   repository       = "https://charts.helm.sh/stable"
  • Network accessline 837
    name             = "spark-history-server"   repository       = "https://charts.helm.sh/stable"   chart            = "spark-history-server"
  • Network accessline 838
    repository       = "https://charts.helm.sh/stable"
  • Network accessline 1071
    [Credential-related source omitted]
  • Network accessline 1072
    airflow_fernet_key        = var.airflow_fernet_key   dags_git_repo             = "https://github.com/org/airflow-dags.git" }
  • Network accessline 1073
    dags_git_repo             = "https://github.com/org/airflow-dags.git"

skills/trino_iceberg/SKILL.md

  • Network accessline 898
    - Local deep-dive spec: `docs/specs/trino_iceberg_performance_optimization.md` - Trino optimizer: https://trino.io/docs/current/optimizer.html
  • Network accessline 899
    - Trino optimizer: https://trino.io/docs/current/optimizer.html
  • Network accessline 900
    - Trino Iceberg connector: https://trino.io/docs/current/connector/iceberg.html

skills/vertica_query_optimization/SKILL.md

  • Network accessline 623
    - Local deep-dive spec: `/docs/specs/vertica_query_optimization_v11.md` - Vertica 11.1.x Query Optimization: https://docs.vertica.com/11.1.x/en/data-analysis/query-optimization/
  • Network accessline 624
    - Vertica 11.1.x Query Optimization: https://docs.vertica.com/11.1.x/en/data-analysis/query-optimization/
  • Network accessline 625
    - Vertica 11.1.x EXPLAIN: https://docs.vertica.com/11.1.x/en/sql-reference/statements/explain/
  • Network accessline 626
    - Vertica 11.1.x Projections: https://docs.vertica.com/11.1.x/en/concepts/projections/
  • Network accessline 627
    - Vertica 11.1.x Analytic Functions: https://docs.vertica.com/11.1.x/en/sql-reference/functions/analytic-functions/

How the signals fit together

Facts from a static read of the files at the pinned commit. They describe what the code does, not why.

Some files could not be read; the facts below still hold.

Combined signals: 4 facts
Signal confidence: 496 facts

and 446 more

Only the first 500 facts are listed.

Works with

  • Native The repository ships a manifest, folder or frontmatter field for this agent.
  • Compatible A standard SKILL.md that this agent can read.
  • Unknown No evidence either way.

Derived automatically from paths, manifests and frontmatter. Not tested on each agent.