[Bugfix] Fix redundant shm broadcast warnings in diffusion workers (#133)

Signed-off-by: samithuang <285365963@qq.com>

vllm_omni/diffusion/worker/gpu_worker.py

@@ -129,7 +129,7 @@ class WorkerProc:
         """
         Receive requests from broadcast queue
         """
-        return self.mq.dequeue()
+        return self.mq.dequeue(indefinite=True)
 
     # TODO: queueing, cancellation
     def worker_busy_loop(self) -> None:

vllm_omni/diffusion/worker/npu/npu_worker.py

@@ -129,7 +129,7 @@ class NPUWorkerProc:
         """
         Receive requests from broadcast queue
         """
-        return self.mq.dequeue()
+        return self.mq.dequeue(indefinite=True)
 
     # TODO: queueing, cancellation
     def worker_busy_loop(self) -> None: