Skip to content

Commit 596bd87

Browse files
committed
updates to use custom status instead of notifications
1 parent be56684 commit 596bd87

File tree

10 files changed

+694
-1226
lines changed

10 files changed

+694
-1226
lines changed

README.md

Lines changed: 6 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -113,16 +113,16 @@ POST http://localhost:3008/returns
113113
All workflows use descriptive activity names for clear dashboard visualization:
114114

115115
**Bulk Processing:**
116-
- `announce_bulk_order_started``announce_child_workflow_spawned``announce_waiting_for_children`
117-
- `announce_item_success` / `announce_item_failure``announce_bulk_order_completed`
116+
- `bulk_order_started``child_workflow_spawned``waiting_for_children`
117+
- `item_success` / `item_failure``bulk_order_completed`
118118

119119
**Returns Processing:**
120-
- `announce_return_request_received``announce_return_validation_started``announce_return_approval_required`
121-
- `announce_defective_return_started` / `announce_standard_refund_processing` / `announce_expedited_parallel_processing`
120+
- `return_request_received``return_validation_started``return_approval_required`
121+
- `defective_return_started` / `standard_refund_processing` / `expedited_parallel_processing`
122122

123123
**Chaos Engineering:**
124-
- `announce_failure_injection_started``execute_retry_policy_test``execute_circuit_breaker_test`
125-
- `announce_external_event_starvation_started``announce_child_workflow_zombie_detected`
124+
- `failure_injection_started``execute_retry_policy_test``execute_circuit_breaker_test`
125+
- `external_event_starvation_started``child_workflow_zombie_detected`
126126

127127
### Circuit Breaker Monitoring
128128
Real-time circuit breaker status available at:

bulk-demo.http

Lines changed: 1 addition & 68 deletions
Original file line numberDiff line numberDiff line change
@@ -39,9 +39,7 @@ Content-Type: application/json
3939
{
4040
"customer": "alice",
4141
"items": [
42-
{"item": "apple", "quantity": 2, "price": 50.0},
43-
{"item": "orange", "quantity": 1, "price": 75.0},
44-
{"item": "pear", "quantity": 3, "price": 30.0}
42+
{"item": "apple", "quantity": 2, "price": 50.0}
4543
]
4644
}
4745

@@ -137,68 +135,3 @@ GET http://localhost:3007/bulk-orders/{{mixed_bulk_instance_id}}
137135
@single_bulk_instance_id = {{single_item_bulk.response.body.instance_id}}
138136

139137
GET http://localhost:3007/bulk-orders/{{single_bulk_instance_id}}
140-
141-
### =============================================
142-
### BULK ORDER WORKFLOW DEMONSTRATION POINTS
143-
### =============================================
144-
###
145-
### 🎯 KEY FEATURES TO HIGHLIGHT:
146-
###
147-
### 1. PARENT-CHILD WORKFLOW ORCHESTRATION:
148-
### - Single bulk order creates multiple child workflows
149-
### - Each item processed independently with parallel execution
150-
### - Parent workflow coordinates and tracks all children
151-
### - Clear activity names for workflow visualization
152-
###
153-
### 2. ADVANCED ACTIVITY NAMING:
154-
### - announce_bulk_order_started: Clear workflow initiation
155-
### - announce_child_workflow_spawned: Track child creation
156-
### - announce_waiting_for_children: Parent coordination point
157-
### - announce_item_success/failure: Individual outcomes
158-
### - announce_inventory_reserved: Business logic completion
159-
### - announce_payment_processing: Payment stage identification
160-
### - announce_shipping_scheduled: Final fulfillment step
161-
###
162-
### 3. REAL-TIME MONITORING:
163-
### - Live notifications with [BULK] prefix in UI
164-
### - Parent and child workflow status tracking
165-
### - Progress updates for each processing stage
166-
### - Failure isolation between child workflows
167-
###
168-
### 4. APPROVAL WORKFLOW INTEGRATION:
169-
### - Automatic approval detection for high-value items
170-
### - External event handling for manager approvals
171-
### - Individual item approval within bulk orders
172-
### - Timeout handling for pending approvals
173-
###
174-
### 5. PARALLEL PROCESSING BENEFITS:
175-
### - Multiple items processed simultaneously
176-
### - Inventory reservation coordination
177-
### - Payment processing optimization
178-
### - Shipping schedule coordination
179-
###
180-
### 6. FAILURE HANDLING:
181-
### - Graceful handling of partial bulk order failures
182-
### - Individual item failure isolation
183-
### - Compensation patterns for failed items
184-
### - Parent workflow status aggregation
185-
###
186-
### 7. SCALABILITY DEMONSTRATION:
187-
### - Bulk orders of varying sizes (1-10+ items)
188-
### - Mixed-value scenarios with differential processing
189-
### - Resource efficient child workflow spawning
190-
### - Coordinated completion handling
191-
###
192-
### =============================================
193-
### 🚀 DEMO EXECUTION GUIDE:
194-
###
195-
### TIMING: Execute requests with 10-15 second delays for observation
196-
### MONITORING: Keep notifications UI (localhost:8080) open during demo
197-
### OBSERVATION: Watch for parent workflow coordination messages
198-
### ANALYSIS: Use workflow IDs to trace parent-child relationships
199-
### APPROVAL: Use actual child workflow IDs from bulk order responses
200-
###
201-
### EXPECTED DEMO DURATION: 5-10 minutes for complete demonstration
202-
### CONCURRENT PROCESSING: Child workflows execute in parallel
203-
### NOTIFICATION RATE: Expect 5-15 events per bulk order
204-
### =============================================

dapr.yaml

Lines changed: 0 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -16,10 +16,6 @@ apps:
1616
appPort: 3003
1717
appDirPath: ./services/payments
1818
command: ["python3", "app.py"]
19-
- appID: notifications
20-
appPort: 8080
21-
appDirPath: ./services/notifications
22-
command: ["npm", "run", "dev"]
2319
- appID: shipping
2420
appPort: 3004
2521
appDirPath: ./services/shipping

return-demo.http

Lines changed: 7 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -249,13 +249,13 @@ GET http://localhost:3008/returns/{{concurrent_defective_id}}
249249
### - External event integration with timeouts and fallbacks
250250
###
251251
### 2. ADVANCED ACTIVITY NAMING:
252-
### - announce_return_request_received: Clear workflow entry point
253-
### - announce_return_validation_started: Eligibility checking phase
254-
### - announce_return_approval_required: High-value return detection
255-
### - announce_return_child_workflow_spawned: Type-specific processing
256-
### - announce_defective_return_started: Defective item workflow
257-
### - announce_standard_refund_processing: Standard return path
258-
### - announce_expedited_parallel_processing: Fast-track processing
252+
### - return_request_received: Clear workflow entry point
253+
### - return_validation_started: Eligibility checking phase
254+
### - return_approval_required: High-value return detection
255+
### - return_child_workflow_spawned: Type-specific processing
256+
### - defective_return_started: Defective item workflow
257+
### - standard_refund_processing: Standard return path
258+
### - expedited_parallel_processing: Fast-track processing
259259
###
260260
### 3. DYNAMIC CHILD WORKFLOWS BY RETURN TYPE:
261261
### - DEFECTIVE: Full refund, no restocking (disposal path)

0 commit comments

Comments
 (0)