diff --git a/ocp_pipeline/opm.py b/ocp_pipeline/opm.py index ee0495c..2b1e977 100644 --- a/ocp_pipeline/opm.py +++ b/ocp_pipeline/opm.py @@ -781,8 +781,10 @@ def handle_m(m): ev.wait(timeout) self.bus.remove("ovos.common_play.SEI.get.response", handle_m) - return player + if not ev.is_set(): + LOG.warning(f"Player synchronization timed out after {timeout} seconds") + return player def get_player(self, message: Optional[Message] = None, timeout=1) -> OCPPlayerProxy: """get a PlayerProxy object, containing info such as player state and the available stream extractors from OCP this is tracked per Session, if needed requests the info from the client"""