القائمة
Skill for the Pipeline area of tone. 85 symbols across 30 files.
التثبيت باستخدام Codex أو Claude انسخ هذا Prompt والصقه في Codex أو Claude أو مساعد آخر ليراجع صفحة Skill ويثبّتها لك.
استنادا إلى تصنيف SOC المهني
Use this skill when the user asks to "review my changes", "code review", "review before commit", "/code-review", or wants SOLID, security, performance, accessibility, or error handling analysis on current git changes. Accepts an optional base branch argument (defaults to main).
Generates feature documentation for a Next.js page by analyzing component source, service imports, Jotai atoms, and navigation paths. Output placed in e2e/ux_flow_docs/<page-name>.md and consumed by /generate-tests for comprehensive test coverage.
Generates a new Playwright e2e spec file by reading a page component's source code, then runs it. Use when a page has NO existing spec file and you need to create one from scratch.
Skill for the Test-cases area of tone. 250 symbols across 60 files.
Generate and maintain pytest test cases for FastAPI endpoints by reading the APIs.md documentation and tracing actual controller/service code. Creates one test file per controller with comprehensive coverage (success, failure, validation, auth, edge cases). Use this skill when the user asks to generate tests, create test cases, write API tests, add pytest coverage, or mentions "test my APIs". Also triggers on "generate tests", "write test cases", "add test coverage", or "pytest for my endpoints".
Creates a new shared UI component using shadcn/ui with the project's theme. Handles shadcn setup verification, theme token mapping, and generates production-ready components following project conventions.
| name | pipeline |
| description | Skill for the Pipeline area of tone. 85 symbols across 30 files. |
85 symbols | 30 files | Cohesion: 60%
pipecat/| File | Symbols |
|---|---|
pipecat/src/pipecat/pipeline/task.py | _create_tasks, _maybe_start_idle_task, _wait_for_pipeline_start, _wait_for_pipeline_end, wait_for_cancel (+17) |
pipecat/src/pipecat/pipeline/task_observer.py | on_process_frame, on_push_frame, _send_to_proxy, TaskObserver, Proxy (+5) |
pipecat/src/pipecat/pipeline/pipeline.py | PipelineSource, init, PipelineSink, setup, _setup_processors (+2) |
pipecat/src/pipecat/pipeline/sync_parallel_pipeline.py | SyncFrame, process_frame, wait_for_sync, SyncParallelPipelineSource, init (+1) |
pipecat/src/pipecat/pipeline/runner.py | init, _setup_sigint, _setup_sigterm, _sig_handler, _sig_cancel |
pipecat/src/pipecat/pipeline/service_switcher.py | init, ServiceSwitcherFilter, _make_pipeline_definitions, _make_pipeline_definition |
core/context.py | get_tenant_context, get_current_user_id |
core/test_case/test_agent_upsert.py | receive, add_message |
pipecat/src/pipecat/processors/frame_processor.py | get, put |
pipecat/src/pipecat/processors/metrics/sentry.py | setup, _sentry_task_handler |
Start here when exploring this area:
get_tenant_context (Function) — core/context.py:16get_current_user_id (Function) — core/context.py:28receive (Function) — core/test_case/test_agent_upsert.py:72user_id (Function) — core/services/base.py:21get (Function) — pipecat/src/pipecat/processors/frame_processor.py:123| Symbol | Type | File | Line |
|---|---|---|---|
SyncFrame | Class | pipecat/src/pipecat/pipeline/sync_parallel_pipeline.py | 27 |
TaskObserver | Class | pipecat/src/pipecat/pipeline/task_observer.py | 41 |
IdleFrameObserver | Class | pipecat/src/pipecat/pipeline/task.py | 64 |
SystemClock | Class | pipecat/src/pipecat/clocks/system_clock.py | 13 |
BaseClock | Class | pipecat/src/pipecat/clocks/base_clock.py | 11 |
TurnTraceObserver | Class | pipecat/src/pipecat/utils/tracing/turn_trace_observer.py | 32 |
GoogleRTVIProcessor | Class | pipecat/src/pipecat/services/google/rtvi.py | 91 |
RTVIProcessor | Class | pipecat/src/pipecat/processors/frameworks/rtvi.py | 1324 |
CustomAddObserver2 | Class | pipecat/tests/test_pipeline.py | 146 |
PipelineSource | Class | pipecat/src/pipecat/pipeline/pipeline.py | 20 |
PipelineSink | Class | pipecat/src/pipecat/pipeline/pipeline.py | 54 |
Proxy | Class | pipecat/src/pipecat/pipeline/task_observer.py | 24 |
HeartbeatFrame | Class | pipecat/src/pipecat/frames/frames.py | 1793 |
ServiceSwitcherFilter | Class | pipecat/src/pipecat/pipeline/service_switcher.py | 124 |
SyncParallelPipelineSource | Class | pipecat/src/pipecat/pipeline/sync_parallel_pipeline.py | 37 |
SyncParallelPipelineSink | Class | pipecat/src/pipecat/pipeline/sync_parallel_pipeline.py | 69 |
get_tenant_context | Function | core/context.py | 16 |
get_current_user_id | Function | core/context.py | 28 |
receive | Function | core/test_case/test_agent_upsert.py | 72 |
user_id | Function | core/services/base.py | 21 |
| Flow | Type | Steps |
|---|---|---|
Process_frame → Put | cross_community | 6 |
Run_tts → Put | cross_community | 6 |
Process_frame → Get | cross_community | 6 |
Start → Get | cross_community | 5 |
Start → Get | cross_community | 5 |
Run_tts → Put | cross_community | 4 |
Run_tts → Put | cross_community | 4 |
Run_tts → Put | cross_community | 3 |
Run_tts → Put | cross_community | 3 |
Run_tts → Put | cross_community | 3 |
| Area | Connections |
|---|---|
| Foundational | 13 calls |
| Tests | 4 calls |
| Daily | 3 calls |
| Tracing | 2 calls |
| Processors | 2 calls |
| Asyncio | 1 calls |
| 1 calls | |
| Smallwebrtc | 1 calls |
gitnexus_context({name: "get_tenant_context"}) — see callers and calleesgitnexus_query({query: "pipeline"}) — find related execution flows