Build a Work-in-Progress Conveyor Transfer and Reroute Dispatcher

Track simulated conveyor queue jams and workstation cycle delays. Synthesize dynamic lot reroute proposals across parallel assembly lines to protect target throughput.

Manufacturing Line Dispatch Supervisor

Ingest simulated open62541 OPC UA sensor signals indicating conveyor station occupancy.

Identify accumulation bottlenecks and downstream queue overflows across cells.

Calculate alternate routing paths based on station availability and remaining work duration.

Format structured lot transfer proposals for floor supervisor authorization.

Interactive conveyor flow topology with congested line warnings and lot transfer approval cards.

Create synthetic JSON streams containing conveyor photoelectric sensor states and pallet RFID tags. Serve via local Python WebSocket. Starter examples below are synthetic. They are not downloaded records.

open62541 OPC UA OPC UA information model representing conveyor status, sensor variables, and sub-assembly line telemetry from open62541.

ray-serve, pydantic, fastapi. Ray Serve enables high-concurrency simulation of parallel assembly lines and queue state evaluation. Low-latency LLM endpoint for real-time queue classification and dispatch formulation.

Submit runnable source, pinned dependencies, setup commands, a working interface, example outputs, and a recorded end-to-end demo. Include tests and an action log.

Detects conveyor line congestion when pallet accumulation exceeds buffer limits.

Proposes valid diversion routes matching part process constraints.

Rejects diversion routes that would starve upstream critical path operations.

```json [ { "input": { "conveyor_zones": [ { "zone_id": "ZONE_C1", "capacity": 10, "current_occupancy": 10, "status": "CONGESTED" }, { "zone_id": "ZONE_C2", "capacity": 10, "current_occupancy": 3, "status": "NOMINAL" } ], "divert_points": [ { "divert_id": "DIVERT_01", "source_zone": "ZONE_C1", "target_zone": "ZONE_C2", "active": true } ], "queued_lot": { "lot_id": "LOT_404", "recipe_type": "TYPE_B", "compatible_lines": [ "ZONE_C1", "ZONE_C2" ] } }, "expected_output": { "reroute_recommended": true, "lot_id": "LOT_404", "target_zone": "ZONE_C2", "diversion_path": "DIVERT_01", "rationale": "ZONE_C1 at capacity; diverting LOT_404 preserves line throughput." } }, { "input": { "conveyor_zones": [ { "zone_id": "ZONE_C1", "capacity": 10, "current_occupancy": 5, "status": "NOMINAL" }, { "zone_id": "ZONE_C2", "capacity": 10, "current_occupancy": 4, "status": "NOMINAL" } ], "divert_points": [], "queued_lot": { "lot_id": "LOT_405", "recipe_type": "TYPE_A", "compatible_lines": [ "ZONE_C1" ] } }, "expected_output": { "reroute_recommended": false, "lot_id": "LOT_405", "target_zone": "ZONE_C1", "diversion_path": null, "rationale": "Line loading balanced; no reroute required." } } ] ```

Read-only simulation. Dispatch and diversion outputs are displayed as suggestions for human operator confirmation. Use mock external writes. Require human review before any real deployment.