Spaces:
Sleeping
Sleeping
Update
Browse files
src/inference_server/session_manager.py
CHANGED
@@ -155,11 +155,6 @@ class InferenceSession:
|
|
155 |
# Connect to rooms
|
156 |
await self._connect_to_rooms()
|
157 |
|
158 |
-
# Start receiving video frames from all cameras
|
159 |
-
for camera_name, consumer in self.camera_consumers.items():
|
160 |
-
await consumer.start_receiving()
|
161 |
-
logger.info(f"Started receiving frames for camera: {camera_name}")
|
162 |
-
|
163 |
# Start timeout monitoring
|
164 |
self.timeout_check_task = asyncio.create_task(self._timeout_monitor())
|
165 |
|
@@ -306,6 +301,12 @@ class InferenceSession:
|
|
306 |
logger.error(msg)
|
307 |
|
308 |
self.status = "running"
|
|
|
|
|
|
|
|
|
|
|
|
|
309 |
self.inference_task = asyncio.create_task(self._inference_loop())
|
310 |
logger.info(f"Started inference for session {self.session_id}")
|
311 |
|
|
|
155 |
# Connect to rooms
|
156 |
await self._connect_to_rooms()
|
157 |
|
|
|
|
|
|
|
|
|
|
|
158 |
# Start timeout monitoring
|
159 |
self.timeout_check_task = asyncio.create_task(self._timeout_monitor())
|
160 |
|
|
|
301 |
logger.error(msg)
|
302 |
|
303 |
self.status = "running"
|
304 |
+
|
305 |
+
# Start receiving video frames from all cameras
|
306 |
+
for camera_name, consumer in self.camera_consumers.items():
|
307 |
+
await consumer.start_receiving()
|
308 |
+
logger.info(f"Started receiving frames for camera: {camera_name}")
|
309 |
+
|
310 |
self.inference_task = asyncio.create_task(self._inference_loop())
|
311 |
logger.info(f"Started inference for session {self.session_id}")
|
312 |
|