class HybridTrackingSystem:
    def __init__(self):
        self.detector = YOLO("yolov8x-worldv2.pt")  # 30+ fps
        self.tracker = ByteTrack()                   # Real-time association
        self.vla = OpenVLAWrapper()                  # 5-10 fps semantic enrichment
        self.vla_queue = asyncio.Queue(maxsize=4)    # Async buffering
        
    async def process_frame(self, frame):
        # Layer 1: High-speed detection (every frame)
        detections = self.detector(frame, verbose=False)[0]
        
        # Layer 2: Temporal association (every frame)
        tracks = self.tracker.update(detections)
        
        # Layer 3: Async VLA enrichment (every 5-10 frames)
        if self.frame_count % self.vla_interval == 0:
            await self.vla_queue.put({
                'frame': frame,
                'tracks': tracks,
                'timestamp': time.time()
            })
        
        # Apply available VLA results with temporal interpolation
        enriched_tracks = self.apply_vla_updates(tracks)
        return enriched_tracks
    
    async def vla_worker(self):
        while True:
            item = await self.vla_queue.get()
            vla_output = await self.vla.process(
                frames=self.get_temporal_window(item),
                query=self.generate_tracking_query(item['tracks'])
            )
            self.update_track_cache(item['timestamp'], vla_output)