diff --git a/pyproject.toml b/pyproject.toml index ed2c9b8..6f33db3 100644 --- a/pyproject.toml +++ b/pyproject.toml @@ -4,7 +4,7 @@ build-backend = "setuptools.build_meta" [project] name = "socketify" -version = "0.0.26" +version = "0.0.27" dynamic = ["dependencies"] authors = [ { name="Ciro Spaciari", email="ciro.spaciari@gmail.com" }, diff --git a/setup.py b/setup.py index 13a68e1..56cd420 100644 --- a/setup.py +++ b/setup.py @@ -58,7 +58,7 @@ with open("README.md", "r", encoding="utf-8") as fh: setuptools.setup( name="socketify", - version="0.0.26", + version="0.0.27", platforms=["any"], author="Ciro Spaciari", author_email="ciro.spaciari@gmail.com", diff --git a/src/socketify/tasks.py b/src/socketify/tasks.py index a32f8a7..656047f 100644 --- a/src/socketify/tasks.py +++ b/src/socketify/tasks.py @@ -500,11 +500,11 @@ class RequestTask: coro = self._coro self._fut_waiter = None - # _parent_task = current_task(self._loop) - # if _parent_task is not None: - # _leave_task(self._loop, _parent_task) - # self._parent_task = _parent_task - # _enter_task(self._loop, self) + _parent_task = current_task(self._loop) + if _parent_task is not None: + _leave_task(self._loop, _parent_task) + self._parent_task = _parent_task + _enter_task(self._loop, self) # Call either coro.throw(exc) or coro.send(None). try: if exc is None: @@ -574,10 +574,10 @@ class RequestTask: new_exc = RuntimeError(f"Task got bad yield: {result!r}") self._loop.call_soon(self.__step, new_exc, context=self._context) finally: - # _leave_task(self._loop, self) - # if self._parent_task is not None: - # _enter_task(self._loop, self._parent_task) - # self._parent_task = None + _leave_task(self._loop, self) + if self._parent_task is not None: + _enter_task(self._loop, self._parent_task) + self._parent_task = None self = None # Needed to break cycles when an exception occurs. def __wakeup(self, future):