Skip to content
Snippets Groups Projects

Asynchronní joby

Merged Martin Mareš requested to merge mj/jobs into devel
1 file
+ 2
2
Compare changes
  • Side-by-side
  • Inline
+ 2
2
@@ -94,12 +94,12 @@ class TheJob:
@@ -94,12 +94,12 @@ class TheJob:
return
return
job = self.job
job = self.job
logger.info(f'Job: Spouštím job #{job.job_id}')
logger.info(f'Job: Spouštím job #{job.job_id} ({job.type})')
job.state = db.JobState.running
job.state = db.JobState.running
sess.commit()
sess.commit()
try:
try:
_handler_table[job.type](job)
_handler_table[job.type](self)
logger.info(f'Job: Úspěšně dokončen job #{job.job_id}')
logger.info(f'Job: Úspěšně dokončen job #{job.job_id}')
job.state = db.JobState.done
job.state = db.JobState.done
except Exception as e:
except Exception as e:
Loading