We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 06199ea commit 0fa696aCopy full SHA for 0fa696a
ipyparallel/apps/launcher.py
@@ -2,6 +2,7 @@
2
"""Facilities for launching IPython processes asynchronously."""
3
# Copyright (c) IPython Development Team.
4
# Distributed under the terms of the Modified BSD License.
5
+import asyncio
6
import copy
7
import logging
8
import os
@@ -326,8 +327,8 @@ def interrupt_then_kill(self, delay=2.0):
326
327
except Exception:
328
self.log.debug("interrupt failed")
329
pass
- self.killer = self.loop.add_timeout(
330
- self.loop.time() + delay, lambda: self.signal(SIGKILL)
+ self.killer = asyncio.get_event_loop().call_later(
331
+ delay, lambda: self.signal(SIGKILL)
332
)
333
334
# callbacks, etc:
0 commit comments