Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
16 changes: 16 additions & 0 deletions backend/main.py
Original file line number Diff line number Diff line change
Expand Up @@ -21,6 +21,22 @@

load_dotenv()

# Disable getstream's NetworkMonitor ping-loop.
# By default, NetworkMonitor pings 8.8.8.8 / 1.1.1.1 / 208.67.222.222 every
# second per session via run_in_executor. On GKE pods (no CAP_NET_RAW), all
# pings fail immediately with PermissionError, so the executor is spammed with
# ~27 no-op calls/second at 9 concurrent sessions. Disable by replacing
# start_monitoring with a coroutine that does nothing — the WebSocket
# reconnect logic in getstream>=3.3.3 is robust without it.
from getstream.video.rtc.network_monitor import NetworkMonitor # noqa: E402


async def _noop_start_monitoring(self) -> None:
pass


NetworkMonitor.start_monitoring = _noop_start_monitoring


class _DropUserContentFilter(logging.Filter):
"""Drop framework log lines that quote user or agent text verbatim.
Expand Down
2 changes: 1 addition & 1 deletion backend/src/inworld_conversational_assistant/agent.py
Original file line number Diff line number Diff line change
Expand Up @@ -201,7 +201,7 @@ def _get_subscription_config(self):
async def create_agent(**kwargs) -> Agent:
face_processor = MediaPipeFaceProcessor(
model_path=str(MODEL_PATH),
fps=8.0,
fps=2.0,
)

# `DISABLE_ANAM=1` skips the avatar publisher entirely. Used to isolate
Expand Down
Loading