Add test for fetching jobs

tests/conftest.py

@@ -44,7 +44,7 @@ def queue2(connection):
 
 @pytest.yield_fixture
 def scheduler(connection):
-    s = Scheduler('unittest', connection=connection)
+    s = Scheduler(connection=connection)
     try:
         yield s
     finally:

tests/test_scheduler.py

@@ -275,3 +275,22 @@ def test_schedule(scheduler, mock, connection):
     expected = [(job_id, dt)]
 
     assert scheduler.schedule() == expected
+
+
+def test_schedule_fetch_job(scheduler, mock, connection):
+    assert scheduler.schedule() == []
+
+    dt = datetime.utcnow().replace(microsecond=0)
+    scheduler.current_time = lambda: dt
+
+    job_id = b'unittest'
+
+    ret = [(job_id, to_unix(dt))]
+    mock.patch.object(connection, 'zrange', return_value=ret)
+
+    job = Job(connection=connection)
+    mock.patch.object(Job, 'fetch', return_value=job)
+
+    expected = [(job, dt)]
+
+    assert scheduler.schedule(fetch_jobs=True) == expected