|
|
|
@ -126,7 +126,7 @@ class AsyncIOPriorityExecutor(AsyncIOExecutor): |
|
|
|
|
def submit_job(self, job, run_times): |
|
|
|
|
run_times = set(run_times) |
|
|
|
|
|
|
|
|
|
logger = logging.getLogger('zasd') |
|
|
|
|
logger = logging.getLogger('apscheduler') |
|
|
|
|
logger.debug('Incoming submission for job %s with run times:', job.id) |
|
|
|
|
for time in run_times: |
|
|
|
|
logger.debug(' %s', time) |
|
|
|
@ -192,7 +192,7 @@ class AsyncIOPriorityExecutor(AsyncIOExecutor): |
|
|
|
|
job_for_time[time] = job.id |
|
|
|
|
|
|
|
|
|
def commit(self): |
|
|
|
|
logger = logging.getLogger('zasd') |
|
|
|
|
logger = logging.getLogger('apscheduler') |
|
|
|
|
|
|
|
|
|
logger.debug('Committing jobs:') |
|
|
|
|
# Look at every group |
|
|
|
@ -210,7 +210,7 @@ class AsyncIOPriorityExecutor(AsyncIOExecutor): |
|
|
|
|
def on_job_executed(self, event): |
|
|
|
|
time = event.scheduled_run_time |
|
|
|
|
|
|
|
|
|
logger = logging.getLogger('zasd') |
|
|
|
|
logger = logging.getLogger('apscheduler') |
|
|
|
|
logger.debug('Job %s has executed', event.job_id) |
|
|
|
|
|
|
|
|
|
# Find job for job ID |
|
|
|
|