diff --git a/replit_river/task_manager.py b/replit_river/task_manager.py index 30d67a8..0fe4ea4 100644 --- a/replit_river/task_manager.py +++ b/replit_river/task_manager.py @@ -29,6 +29,7 @@ async def cancel_task( background_tasks.remove(task_to_remove) exception = task_to_remove.exception() except (asyncio.CancelledError, ChannelClosed): + # This is expected when websocket is closed logging.debug("Task was cancelled %r", task_to_remove) return except Exception: