return '<Job id=%s>' % self.job_id
-jobs = [Job(x) for x in os.listdir(JOBS_DIR)]
-jobs.sort(lambda x, y: cmp(x.timestamp, y.timestamp))
+if __name__ == '__main__':
+ if not os.path.exists(JOBS_DIR):
+ os.makedirs(JOBS_DIR)
+ jobs = [Job(x) for x in os.listdir(JOBS_DIR)]
+ jobs.sort(lambda x, y: cmp(x.timestamp, y.timestamp))
-running_jobs = [x for x in jobs if x.cmd == 'running']
+ running_jobs = [x for x in jobs if x.cmd == 'running']
-waiting = 0
-for job in jobs:
- if job.cmd == 'start':
- if running_jobs:
- job.add_info('Encore %s jobs ...' % (len(running_jobs)+waiting))
- waiting += 1
- else:
- running_jobs.append(job)
- job.start()
- elif job.cmd == 'done':
- job.cleanup()
+ waiting = 0
+ for job in jobs:
+ if job.cmd == 'start':
+ if running_jobs:
+ job.add_info('Encore %s jobs ...' % (len(running_jobs)+waiting))
+ waiting += 1
+ else:
+ running_jobs.append(job)
+ job.start()
+ elif job.cmd == 'done':
+ job.cleanup()