open_parpool.m

if ~exist('no_par_processes','var')
   no_par_processes=2; 
end


if usejava('desktop')
    disp('Local Job')
    mycluster = 'local';
    mypool = parcluster(mycluster);
else
    
    if contains(getenv('QUEUE'), 'aws-')
        disp('AWS Job')
        mycluster = 'local';
        myfolderbase = strcat(getenv('TMP'), '/');
    else
        disp('HPCC Job')
        mycluster = 'WhartonHPC';
        myfolderbase = '~/matlabtmp/';
    end
    mypool = parcluster(mycluster);
    tmpFolder = strcat(myfolderbase, getenv('JOB_ID'), '-', getenv('SGE_TASK_ID'));
    mkdir(tmpFolder);
    mypool.JobStorageLocation = tmpFolder;
    
end


disp(['PPN: ',num2str(no_par_processes)]);

cp=gcp('nocreate');
if ~isempty(cp)
    if  cp.NumWorkers~=no_par_processes
        delete(cp);
        if no_par_processes>0
            parpool(mypool, no_par_processes);
        end
    end
else
    if no_par_processes>0
        parpool(mypool, no_par_processes);
    end
end