pipeline-conventions

Enforce required implementation conventions for Kafka-based anomaly detection microservices.

Updated Mar 3, 2026
One-click install
npx skills add https://github.com/GaneshMadarasu/real-time-anomaly-detection-pipeline --skill pipeline-conventions
Or copy as Structured Prompt for Agent
Please help me install this Agent Skill.
Skill: pipeline-conventions
Source: https://github.com/GaneshMadarasu/real-time-anomaly-detection-pipeline/tree/main/.claude/skills/pipeline-conventions
Command: npx skills add https://github.com/GaneshMadarasu/real-time-anomaly-detection-pipeline --skill pipeline-conventions

SYSTEM DOCUMENTATION & REQUIREMENTS

What problem does it solve?

This Skill helps teams write and review code for the real-time anomaly detection pipeline without drifting from the project’s required service patterns, runtime behavior, or operational safeguards.

Core Features & Use Cases

  • Project-wide conventions: Applies the same rules for imports, logging, environment variables, health checks, shutdown handling, and service startup across all microservices.
  • Production guardrails: Preserves critical implementation details such as Kafka error handling, Redis usage, River model ordering, Faust compatibility, and TimescaleDB indexing rules.
  • Operational consistency: Supports service code reviews, bug fixes, and new implementation work for producer, feature engineering, inference, drift detection, retraining, and alerting components.

Quick Start

Use this skill to review or draft code for any pipeline service while enforcing the repository’s required logging, shutdown, health, and environment-variable conventions.

Frequently Asked Questions about pipeline-conventions

High-intent search queries and answers about installing and using this skill.

FAQPage Schema
How do I enforce consistent logging and health checks across Kafka-based microservices?

Enforce consistent logging and health checks across Kafka-based microservices by standardizing service code for imports, environment variables, and shutdown handling. This ensures operational consistency across producer, inference, and alerting components.

What conventions are required for Kafka error handling and Redis access in a real-time anomaly detection pipeline?

Required conventions for Kafka error handling and Redis access in a real-time anomaly detection pipeline preserve critical implementation details. They enforce strict adherence to runtime patterns, signal handling, and operational safeguards across all microservices.

How do I standardize River model ordering and Faust compatibility for pipeline services?

Standardize River model ordering and Faust compatibility by applying project-wide conventions to service code reviews and new implementations. This maintains production guardrails across feature engineering, drift detection, and retraining services.

Can I use this approach to troubleshoot TimescaleDB indexing rules in microservice systems?

Yes, you can troubleshoot TimescaleDB indexing rules in microservice systems by enforcing required implementation conventions. This supports bug fixes and operational consistency for drift detection and alerting services.

Do I need specific dependencies to standardize service code for anomaly detection pipelines?

No specific dependencies are required to standardize service code for anomaly detection pipelines. The Skill applies required implementation conventions and runtime patterns directly to authoring and reviewing microservice components.

What's the best way to review code for real-time anomaly detection pipeline services?

The best way to review code for real-time anomaly detection pipeline services is enforcing repository conventions for logging, shutdown, health, and environment variables. This preserves production guardrails across all Kafka-based microservices.