environment/lib/python2.7/site-packages/IPython/parallel/controller/scheduler.py
def submit_task(self, job, indices=None):
        """Submit a task to any of a subset of our targets."""
        if indices:
            loads = [self.loads[i] for i in indices]
        else:
            loads = self.loads
        idx = self.scheme(loads)
        if indices:
            idx = indices[idx]
        target = self.targets[idx]
        # print (target, map(str, msg[:3]))
        # send job to the engine
        self.engine_stream.send(target, flags=zmq.SNDMORE, copy=False)
        self.engine_stream.send_multipart(job.raw_msg, copy=False)
        # update load
        self.add_job(idx)
        self.pending[target][job.msg_id] = job
        # notify Hub
        content = dict(msg_id=job.msg_id, engine_id=target.decode('ascii'))
        self.session.send(self.mon_stream, 'task_destination', content=content,
                        ident=[b'tracktask',self.ident])
def submit_task(self, job, indices=None):
        if indices:
            loads = [self.loads[i] for i in indices]
        else:
            loads = self.loads
        idx = self.scheme(loads)
        if indices:
            idx = indices[idx]
        target = self.targets[idx]
        # print (target, map(str, msg[:3]))
        # send job to the engine
        self.engine_stream.send(target, flags=zmq.SNDMORE, copy=False)
        self.engine_stream.send_multipart(job.raw_msg, copy=False)
        # update load
        self.add_job(idx)
        self.pending[target][job.msg_id] = job
        # notify Hub
        content = dict(msg_id=job.msg_id, engine_id=target.decode('ascii'))
        self.session.send(self.mon_stream, 'task_destination', content=content,
                        ident=[b'tracktask',self.ident])
def submit_task ( self , job , indices = None ) : if indices : loads = [ self . loads [ i ] for i in indices ] else : loads = self . loads idx = self . scheme ( loads ) if indices : idx = indices [ idx ] target = self . targets [ idx ] # print (target, map(str, msg[:3])) # send job to the engine self . engine_stream . send ( target , flags = zmq . SNDMORE , copy = False ) self . engine_stream . send_multipart ( job . raw_msg , copy = False ) # update load self . add_job ( idx ) self . pending [ target ] [ job . msg_id ] = job # notify Hub content = dict ( msg_id = job . msg_id , engine_id = target . decode ( 'ascii' ) ) self . session . send ( self . mon_stream , 'task_destination' , content = content , ident = [ b'tracktask' , self . ident ] )
Submit a task to any of a subset of our targets.
Submit a task to any of a subset of our targets .