refactor: centralize scheduler initialization and improve logging in job files
parent
caf89e39a7
commit
948ec2fde6
|
|
@ -38,6 +38,6 @@ def run():
|
||||||
clean_debug_file_job = scheduler.get_job(job_id='clean_debug_file')
|
clean_debug_file_job = scheduler.get_job(job_id='clean_debug_file')
|
||||||
if clean_debug_file_job is not None:
|
if clean_debug_file_job is not None:
|
||||||
clean_debug_file_job.remove()
|
clean_debug_file_job.remove()
|
||||||
scheduler.add_job(clean_debug_file, 'cron', hour='*', minute='*/1', second='0', id='clean_debug_file')
|
scheduler.add_job(clean_debug_file, 'cron', hour='*', minute='*/30', second='0', id='clean_debug_file')
|
||||||
finally:
|
finally:
|
||||||
un_lock('clean_debug_file')
|
un_lock('clean_debug_file')
|
||||||
|
|
|
||||||
Loading…
Reference in New Issue