diff --git a/poetry.lock b/poetry.lock index 4f9aaed..6ac9899 100644 --- a/poetry.lock +++ b/poetry.lock @@ -2465,4 +2465,4 @@ type = ["pytest-mypy"] [metadata] lock-version = "2.0" python-versions = "^3.12" -content-hash = "66a54d26a954041e335b695e0a74dc24703ea60b2cb0ac04900f3728dd7ef17c" +content-hash = "0c60512d5a9051c7b022d787bcb5830266e5496fe3c5e22ed3c7049174bf6312" diff --git a/pyproject.toml b/pyproject.toml index cba8985..50dff07 100644 --- a/pyproject.toml +++ b/pyproject.toml @@ -22,7 +22,7 @@ readme = "README.md" [tool.poetry.dependencies] python = "^3.12" aio-pika = "^9.0" -wsaccel = "^0.6.4" +wsaccel = "^0.6.7" ws4py = "^0.5.1" attrs = "^23.1.0" asyncclick = "^8.1.3.4" diff --git a/tvt_agents/__main__.py b/tvt_agents/__main__.py index a98a8a5..99e3423 100644 --- a/tvt_agents/__main__.py +++ b/tvt_agents/__main__.py @@ -58,7 +58,7 @@ async def run_websocket_source_loop( loop_logger.error("WS source not specified!") raise ValueError wsaccel.patch_ws4py() - dist = Distributor(loop_logger) + dist = Distributor() dist.logger = loop_logger ws_source = WebSocketSource( websocket_url,