environment/lib/python2.7/site-packages/IPython/parallel/apps/launcher.py
def write_batch_script(self, n):
        """Instantiate and write the batch script to the work_dir."""
        self.n = n
        # first priority is batch_template if set
        if self.batch_template_file and not self.batch_template:
            # second priority is batch_template_file
            with open(self.batch_template_file) as f:
                self.batch_template = f.read()
        if not self.batch_template:
            # third (last) priority is default_template
            self.batch_template = self.default_template

            # add jobarray or queue lines to user-specified template
            # note that this is *only* when user did not specify a template.
            # print self.job_array_regexp.search(self.batch_template)
            if not self.job_array_regexp.search(self.batch_template):
                self.log.debug("adding job array settings to batch script")
                firstline, rest = self.batch_template.split('\n',1)
                self.batch_template = u'\n'.join([firstline, self.job_array_template, rest])

            # print self.queue_regexp.search(self.batch_template)
            if self.queue and not self.queue_regexp.search(self.batch_template):
                self.log.debug("adding PBS queue settings to batch script")
                firstline, rest = self.batch_template.split('\n',1)
                self.batch_template = u'\n'.join([firstline, self.queue_template, rest])

        script_as_string = self.formatter.format(self.batch_template, **self.context)
        self.log.debug('Writing batch script: %s', self.batch_file)

        with open(self.batch_file, 'w') as f:
            f.write(script_as_string)
        os.chmod(self.batch_file, stat.S_IRUSR | stat.S_IWUSR | stat.S_IXUSR)
def write_batch_script(self, n):
        self.n = n
        # first priority is batch_template if set
        if self.batch_template_file and not self.batch_template:
            # second priority is batch_template_file
            with open(self.batch_template_file) as f:
                self.batch_template = f.read()
        if not self.batch_template:
            # third (last) priority is default_template
            self.batch_template = self.default_template

            # add jobarray or queue lines to user-specified template
            # note that this is *only* when user did not specify a template.
            # print self.job_array_regexp.search(self.batch_template)
            if not self.job_array_regexp.search(self.batch_template):
                self.log.debug("adding job array settings to batch script")
                firstline, rest = self.batch_template.split('\n',1)
                self.batch_template = u'\n'.join([firstline, self.job_array_template, rest])

            # print self.queue_regexp.search(self.batch_template)
            if self.queue and not self.queue_regexp.search(self.batch_template):
                self.log.debug("adding PBS queue settings to batch script")
                firstline, rest = self.batch_template.split('\n',1)
                self.batch_template = u'\n'.join([firstline, self.queue_template, rest])

        script_as_string = self.formatter.format(self.batch_template, **self.context)
        self.log.debug('Writing batch script: %s', self.batch_file)

        with open(self.batch_file, 'w') as f:
            f.write(script_as_string)
        os.chmod(self.batch_file, stat.S_IRUSR | stat.S_IWUSR | stat.S_IXUSR)
def write_batch_script ( self , n ) : self . n = n # first priority is batch_template if set if self . batch_template_file and not self . batch_template : # second priority is batch_template_file with open ( self . batch_template_file ) as f : self . batch_template = f . read ( ) if not self . batch_template : # third (last) priority is default_template self . batch_template = self . default_template # add jobarray or queue lines to user-specified template # note that this is *only* when user did not specify a template. # print self.job_array_regexp.search(self.batch_template) if not self . job_array_regexp . search ( self . batch_template ) : self . log . debug ( "adding job array settings to batch script" ) firstline , rest = self . batch_template . split ( '\n' , 1 ) self . batch_template = u'\n' . join ( [ firstline , self . job_array_template , rest ] ) # print self.queue_regexp.search(self.batch_template) if self . queue and not self . queue_regexp . search ( self . batch_template ) : self . log . debug ( "adding PBS queue settings to batch script" ) firstline , rest = self . batch_template . split ( '\n' , 1 ) self . batch_template = u'\n' . join ( [ firstline , self . queue_template , rest ] ) script_as_string = self . formatter . format ( self . batch_template , * * self . context ) self . log . debug ( 'Writing batch script: %s' , self . batch_file ) with open ( self . batch_file , 'w' ) as f : f . write ( script_as_string ) os . chmod ( self . batch_file , stat . S_IRUSR | stat . S_IWUSR | stat . S_IXUSR )
Instantiate and write the batch script to the work_dir.
Instantiate and write the batch script to the work_dir .