Cursor rule

1---
2description: "Task type patterns and execution strategies for Compozy workflows"
3globs:
4  - "**/workflow.yaml"
5  - "**/workflows/*.yaml"
6alwaysApply: false
7---
8# Compozy Task Patterns
9 
10<configuration_overview type="task_patterns">
11Task patterns define different types of task execution strategies including basic, composite, parallel, collection, router, signal, and aggregate tasks.
12</configuration_overview>
13 
14## Basic Task Pattern
15 
16<task_patterns type="basic_task">
17```yaml
18# Basic task with tool execution
19- id: weather
20  type: basic
21  $use: tool(local::tools.#(id=="weather_tool"))
22  with:
23    city: "{{ .workflow.input.city }}"
24  outputs:
25    temperature: "{{ .output.temperature }}"
26    city: "{{ .workflow.input.city }}"
27  on_success:
28    next: next_task
29```
30</task_patterns>
31 
32## Composite Task Pattern
33 
34<task_patterns type="composite_task">
35```yaml
36# Composite task containing multiple sub-tasks
37- id: root_composite
38  type: composite
39  strategy: fail_fast
40  tasks:
41    - id: subtask_1
42      type: basic
43      $use: tool(local::tools.#(id=="echo_tool"))
44      with:
45        message: "First subtask"
46    - id: subtask_2
47      type: basic
48      $use: tool(local::tools.#(id=="echo_tool"))
49      with:
50        message: "Second subtask"
51```
52</task_patterns>
53 
54## Parallel Task Pattern
55 
56<task_patterns type="parallel_task">
57```yaml
58# Parallel task execution
59- id: parallel_section
60  type: parallel
61  strategy: wait_all  # or race
62  tasks:
63    - id: task_a
64      type: basic
65      $use: tool(local::tools.#(id=="echo_tool"))
66      with:
67        message: "Parallel Task A"
68    - id: task_b
69      type: basic
70      $use: tool(local::tools.#(id=="echo_tool"))
71      with:
72        message: "Parallel Task B"
73```
74</task_patterns>
75 
76## Collection Task Pattern
77 
78<task_patterns type="collection_task">
79```yaml
80# Collection task for processing arrays
81- id: collection_section
82  type: collection
83  mode: parallel  # or sequential
84  strategy: best_effort  # or fail_fast
85  items: "{{ .workflow.input.test_data }}"
86  task:
87    id: "process-{{ .index }}"
88    type: basic
89    $use: tool(local::tools.#(id=="echo_tool"))
90    with:
91      message: "Processing item: {{ .item }} at index {{ .index }}"
92```
93</task_patterns>
94 
95## Router Task Pattern
96 
97<task_patterns type="router_task">
98```yaml
99# Router task for conditional branching
100- id: clothing_check
101  type: router
102  condition: '{{ .tasks.clothing.output.clothing | empty | ternary "no_clothes" "has_clothes" }}'
103  routes:
104    has_clothes:
105      $ref: local::tasks.#(id="save_results")
106    no_clothes:
107      $ref: local::tasks.#(id="no_results")
108```
109</task_patterns>
110 
111## Signal Task Pattern
112 
113<task_patterns type="signal_task">
114```yaml
115# Signal task for workflow communication
116- id: send-signal
117  type: signal
118  signal:
119    id: workflow-ready
120    payload:
121      message: "Hello from sender!"
122```
123</task_patterns>
124 
125## Aggregate Task Pattern
126 
127<task_patterns type="aggregate_task">
128```yaml
129# Aggregate task for combining outputs
130- id: aggr
131  type: aggregate
132  outputs:
133    city: "{{ .workflow.input.city }}"
134    weather: "{{ .tasks.weather.output }}"
135    activities: "{{ .tasks.activities.output }}"
136    analysis: "{{ .tasks.activity_analysis.output }}"
137```
138</task_patterns>
139 
140## Workflow Configuration Structure
141 
142<workflow_config_pattern type="basic_structure">
143```yaml
144id: workflow-name
145version: 0.1.0
146description: Workflow description
147
148config:
149  input:
150    type: object
151    properties:
152      city:
153        type: string
154        description: The city name
155    required:
156      - city
157
158schemas:
159  - id: city_input
160    type: object
161    properties:
162      city:
163        type: string
164        description: The city to get weather information for
165    required:
166      - city
167
168tools:
169  - id: tool_name
170    description: Tool description
171    execute: ./tool_file.ts
172    input:
173      $ref: local::schemas.#(id=="city_input")
174
175tasks:
176  - id: task_name
177    type: basic
178    $use: tool(local::tools.#(id=="tool_name"))
179    with:
180      city: "{{ .workflow.input.city }}"
181```
182</workflow_config_pattern>
183 
184## Strategy Patterns
185 
186<strategy_patterns type="execution_strategies">
187```yaml
188# Composite task strategies
189strategy: fail_fast    # Stop on first failure
190strategy: best_effort  # Continue despite failures
191 
192# Parallel task strategies
193strategy: wait_all      # Wait for all tasks to complete
194strategy: race          # First task to complete wins
195 
196# Collection task strategies
197strategy: fail_fast     # Stop on first failure
198strategy: best_effort   # Process all items regardless of failures
199```
200</strategy_patterns>
201 
202## Trigger Patterns
203 
204<trigger_patterns type="signal_trigger">
205```yaml
206# Signal-based workflow trigger
207triggers:
208  - type: signal
209    name: workflow-ready
210```
211</trigger_patterns>
212 
213## Tool Configuration
214 
215<tool_config_pattern type="typescript_tool">
216```yaml
217tools:
218  - id: weather_tool
219    description: Get the current weather for a specific location
220    execute: ./weather_tool.ts
221    input:
222      type: object
223      properties:
224        city:
225          type: string
226          description: The city to get weather for
227      required:
228        - city
229
230  - id: save_data
231    description: Save data to a file
232    execute: ./save_tool.ts
233    input:
234      type: object
235      properties:
236        payload:
237          type: object
238        format:
239          type: string
240          enum: ["json", "txt"]
241      required:
242        - payload
243        - format
244```
245</tool_config_pattern>
246 
247## Deno Configuration
248 
249<deno_config_pattern type="tool_imports">
250```json
251{
252  "imports": {
253    "weather_tool": "./weather_tool.ts",
254    "save_data": "./save_tool.ts",
255    "echo_tool": "./echo_tool.ts",
256    "counter_tool": "./counter_tool.ts"
257  },
258  "fmt": {
259    "indentWidth": 4,
260    "useTabs": false,
261    "lineWidth": 100,
262    "singleQuote": false
263  }
264}
265```
266</deno_config_pattern>
267