def submit_combine(self):
    job_ids = self.job_list
    if ((job_ids is not None) and (len(job_ids) > 20)):
        print('WARNING: boto3 cannot support waiting for more than 20 jobs.')
        print('Please wait for the reading to finish, then run again with the')
        print('`combine` option.')
        return
    environment_vars = get_environment()
    job_name = ('%s_combine_reading_results' % self.basename)
    command_list = get_batch_command((['python', '-m', 'indra.tools.reading.assemble_reading_stmts_aws', self.basename, '-r'] + self.readers), purpose='pmid_reading', project=self.project_name)
    logger.info(('Command list: %s' % str(command_list)))
    kwargs = {'jobName': job_name, 'jobQueue': self._job_queue, 'jobDefinition': self._job_def, 'containerOverrides': {'environment': environment_vars, 'command': command_list, 'memory': 60000, 'vcpus': 1}}
    if job_ids:
        kwargs['dependsOn'] = job_ids
    batch_client = boto3.client('batch')
    batch_client.submit_job(**kwargs)
    logger.info('submitted...')
    return
def submit_combine(self):
    job_ids = self.job_list
    if ((job_ids is not None) and (len(job_ids) > 20)):
        print('WARNING: boto3 cannot support waiting for more than 20 jobs.')
        print('Please wait for the reading to finish, then run again with the')
        print('`combine` option.')
        return
    environment_vars = get_environment()
    job_name = ('%s_combine_reading_results' % self.basename)
    command_list = get_batch_command((['python', '-m', 'indra.tools.reading.assemble_reading_stmts_aws', self.basename, '-r'] + self.readers), purpose='pmid_reading', project=self.project_name)
    logger.info(('Command list: %s' % str(command_list)))
    kwargs = {'jobName': job_name, 'jobQueue': self._job_queue, 'jobDefinition': self._job_def, 'containerOverrides': {'environment': environment_vars, 'command': command_list, 'memory': 60000, 'vcpus': 1}}
    if job_ids:
        kwargs['dependsOn'] = job_ids
    batch_client = boto3.client('batch')
    batch_client.submit_job(**kwargs)
    logger.info('submitted...')
    return