In [1]:

import ipyparallel as ipp
client = ipp.Client()
dview = client[:]
dview

Out[1]:

<DirectView [1, 2, 3, 4,...]>

In [2]:

import signal
engine_pids = client[:].apply(os.getpid).get_dict()

def signal_engine(engine_id, sig=signal.SIGINT):
    """send a signal to a local engine"""
    pid = engine_pids[engine_id]
    os.kill(pid, sig)

In [3]:

import time

ar = client[1].apply_async(time.sleep, 10)
time.sleep(1)
signal_engine(1)
ar.get()

---------------------------------------------------------------------------KeyboardInterrupt                         Traceback (most recent call last)<string> in <module>()
KeyboardInterrupt: