environment/lib/python2.7/site-packages/IPython/parallel/apps/launcher.py
def start(self, n):
        """Start n copies of the process using LSF batch system.
        This cant inherit from the base class because bsub expects
        to be piped a shell script in order to honor the #BSUB directives :
        bsub < script
        """
        # Here we save profile_dir in the context so they
        # can be used in the batch script template as {profile_dir}
        self.write_batch_script(n)
        #output = check_output(self.args, env=os.environ)
        piped_cmd = self.args[0]+'<\"'+self.args[1]+'\"'
        self.log.debug("Starting %s: %s", self.__class__.__name__, piped_cmd)
        p = Popen(piped_cmd, shell=True,env=os.environ,stdout=PIPE)
        output,err = p.communicate()
        job_id = self.parse_job_id(output)
        self.notify_start(job_id)
        return job_id
def start(self, n):
        """Start n copies of the process using LSF batch system.
        This cant inherit from the base class because bsub expects
        to be piped a shell script in order to honor the #BSUB directives :
        bsub < script
        """
        # Here we save profile_dir in the context so they
        # can be used in the batch script template as {profile_dir}
        self.write_batch_script(n)
        #output = check_output(self.args, env=os.environ)
        piped_cmd = self.args[0]+'<\"'+self.args[1]+'\"'
        self.log.debug("Starting %s: %s", self.__class__.__name__, piped_cmd)
        p = Popen(piped_cmd, shell=True,env=os.environ,stdout=PIPE)
        output,err = p.communicate()
        job_id = self.parse_job_id(output)
        self.notify_start(job_id)
        return job_id
def start ( self , n ) : # Here we save profile_dir in the context so they # can be used in the batch script template as {profile_dir} self . write_batch_script ( n ) #output = check_output(self.args, env=os.environ) piped_cmd = self . args [ 0 ] + '<\"' + self . args [ 1 ] + '\"' self . log . debug ( "Starting %s: %s" , self . __class__ . __name__ , piped_cmd ) p = Popen ( piped_cmd , shell = True , env = os . environ , stdout = PIPE ) output , err = p . communicate ( ) job_id = self . parse_job_id ( output ) self . notify_start ( job_id ) return job_id
Start n copies of the process using LSF batch system.
        This cant inherit from the base class because bsub expects
        to be piped a shell script in order to honor the #BSUB directives :
        bsub < script
Start n copies of the process using LSF batch system . This cant inherit from the base class because bsub expects to be piped a shell script in order to honor the #BSUB directives : bsub < script