#!/usr/bin/env python
# coding: utf-8

# In[1]:


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


# 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()