fix(tests): fix queue peeking test

This commit is contained in:
Rushabh Mehta 2019-09-25 09:55:17 +05:30
parent c583be6f33
commit e85cd6549c
3 changed files with 8 additions and 3 deletions

View file

@ -1515,6 +1515,8 @@ def log_error(message=None, title=None):
error = get_traceback()
else:
error = message
else:
error = get_traceback()
return get_doc(dict(doctype='Error Log', error=as_unicode(error),
method=title)).insert(ignore_permissions=True)

View file

@ -34,8 +34,8 @@ class ScheduledJobType(Document):
enqueue('frappe.core.doctype.scheduled_job_type.scheduled_job_type.run_scheduled_job',
queue = self.get_queue_name(), job_type=self.method)
return True
else:
return False
return False
def is_event_due(self, current_time = None):
'''Return true if event is due based on time lapsed since last execution'''

View file

@ -37,11 +37,14 @@ class TestScheduler(TestCase):
last_execution = '2010-01-01 00:00:00',
queue = 'All'
)).insert()
frappe.db.commit()
else:
job = frappe.get_doc('Scheduled Job Type', 'test_scheduler.test_timeout')
self.assertTrue(job.enqueue())
print(get_jobs(site=frappe.local.site, key='job_type'))
job.db_set('last_execution', '2010-01-01 00:00:00')
frappe.db.commit()
time.sleep(1) # wait if job is not yet queued
self.assertFalse(job.enqueue())
job.delete()