Jason Mills

I solved this myself, one uses `mock` and patches the `get_jobs_to_queue` method. E.g, ``` def return_all_jobs(scheduler): return scheduler.get_jobs() @mock.patch('rq_scheduler.scheduler.Scheduler.get_jobs_to_queue', return_all_jobs) def test_something_scheduled(): # given that scheduler is an RQ scheduler...

so with empty it would look like something like (for testing): ``` worker = SimpleWorker() scheduler.enqueue_in(...) # some time later to test the results scheduler.empty() worker.work(burst=True) ``` However, in my...

If a redis lock is used, how to ensure that a crashed scheduler doesn't cause a stale lock? Maybe a simple keep alive via redis pub/sub? > On Aug 19,...

Ah, that works. A deadman switch. > On Aug 19, 2015, at 9:32 PM, Selwin Ong [email protected] wrote: > > We can use "redis.expire(30)" so that if scheduler crashes, the...

@sywhang This issue should be closed

@sywhang @abhinav I discovered the issue, which is that in my environment port 8080 is not available to bind too, which causes the tests to fail. These should likely be...

I'm not sure, it was a while ago. Likely Chrome under OS X, but I couldn't venture a guess on version. Thanks, Jason Mills - sent from mobile. > On...