Holon

Swarm Dispatch Manager

Batch holon routing -- round-robin, load-aware, stage-aware strategies for up to 1000 holons.

Swarm Dispatch Manager (v2026-08-02T101544Z-ab2bbdebf5) 2026-08-01 | Batch holon routing -- round-robin, load-aware, stage-aware strategies for up to 1000 holons. 1 - Dispatch Request Handling SwarmDispatchManager dispatch() GET /api/dispatch validate_batch_size len(request.holons) > 1000 validate_batch_exists request.batch_id in self.batches batch request 2 - Batch State Initialization BatchState self.batches[request.batch_id] = batch create_batch_state BatchState(batch_id=request.batch_id, ...) batch state 3 - Routing and Publishing _apply_dispatch_rule self._apply_dispatch_rule(rule=DispatchRule(request.dispatch_rule), ...) MQTTClient self.mqtt.publish(f'kv/batch/{request.batch_id}/started', {...}) _publish_batch_status await self._publish_batch_status(request.batch_id) routing manife… 1. SwarmDispatchManager receiv… 2. validate batch size and exi… 3. create batch state 4. apply dispatch rule 5. publish batch started event 6. publish initial status Batch Dispatch Request Payload { "batch_id": "unique_batch_id", "dispatch_rule": "round_robin", "holons": [...], "timeout_seconds": 300, "notify_on_completion": false } MQTT Publish Payload { "batch_id": "unique_batch_id", "holon_count": 10, "dispatch_rule": "round_robin", "routing_manifest": [...], "timestamp": 1633072800.0 } The source code does not show the implementation of _stage_aware_dispatch method, so it is omitted in the diagram. Legend actor = initiates work · process = code path · store = state on disk · bus = durable queue · dashed = separate process cyan = request flow · pink = state read/write · dashed green = pull / return path · red = refusal

Provenance

This drawing is generated, not drawn. It is rebuilt from the source files below, so when they change the picture changes — a diagram here cannot quietly describe a system that no longer works this way.

Owner
Holon
Slug
swarm-dispatch
Rendered
2026-08-02T101544Z
From commit
ab2bbdebf5
Watches
1 path
  • daemon/src/swarm_dispatch_manager.py