|
|
@@ -93,7 +93,7 @@ class ConnHandlerBeeWatch(digilib.network.ConnHandlerBase):
|
|
|
lserver.debug("exec: "+task.exception.__cause__)
|
|
|
# task joins iself to suppress the "task not joined" warning
|
|
|
cur_task = await curio.current_task()
|
|
|
- await curio.ignore_after(0,cur_task.join)
|
|
|
+ await curio.ignore_after(0,cur_task.wait)
|
|
|
# remove this task from running tasks list
|
|
|
digilib.network._tasks.remove(cur_task)
|
|
|
|
|
|
@@ -109,7 +109,7 @@ class ConnHandlerBeeWatch(digilib.network.ConnHandlerBase):
|
|
|
# lserver.error("error during api_func execution",exc_info=e)
|
|
|
# # we do this so we don't get an "task was not joined" error
|
|
|
# cur_task = await curio.current_task()
|
|
|
- # await curio.ignore_after(0,cur_task.join)
|
|
|
+ # await curio.ignore_after(0,cur_task.wait)
|
|
|
# except Exception as e:
|
|
|
# lserver.error("error",exc_info=e)
|
|
|
|
