Skip to content

Commit

Permalink
Update ocp_pipeline/opm.py
Browse files Browse the repository at this point in the history
Co-authored-by: coderabbitai[bot] <136622811+coderabbitai[bot]@users.noreply.github.com>
  • Loading branch information
JarbasAl and coderabbitai[bot] authored Nov 22, 2024
1 parent 040df19 commit b67064d
Showing 1 changed file with 3 additions and 1 deletion.
4 changes: 3 additions & 1 deletion ocp_pipeline/opm.py
Original file line number Diff line number Diff line change
Expand Up @@ -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"""
Expand Down

0 comments on commit b67064d

Please sign in to comment.