Skip to content

Commit 9d41103

Browse files
committed
fix pytest tests
1 parent a6b75ed commit 9d41103

File tree

2 files changed

+6
-1
lines changed

2 files changed

+6
-1
lines changed

jupyter_scheduler/tests/mocks.py

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,4 +1,6 @@
1+
from multiprocessing import Queue
12
from typing import Dict, List
3+
from unittest.mock import Mock
24

35
from jupyter_scheduler.download_manager import DownloadManager
46
from jupyter_scheduler.environments import EnvironmentManager
@@ -78,4 +80,4 @@ def resume_jobs(self, job_definition_id: str):
7880

7981
class MockDownloadManager(DownloadManager):
8082
def __init__(self, db_url: str):
81-
pass
83+
self.queue = Queue()

jupyter_scheduler/tests/test_execution_manager.py

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -7,6 +7,7 @@
77
from conftest import DB_URL
88
from jupyter_scheduler.executors import DefaultExecutionManager
99
from jupyter_scheduler.orm import Job
10+
from jupyter_scheduler.tests.mocks import MockDownloadManager
1011

1112
JOB_ID = "69856f4e-ce94-45fd-8f60-3a587457fce7"
1213
NOTEBOOK_NAME = "side_effects.ipynb"
@@ -30,11 +31,13 @@ def load_job(jp_scheduler_db):
3031

3132

3233
def test_add_side_effects_files(jp_scheduler_db, load_job):
34+
download_manager = MockDownloadManager(DB_URL)
3335
manager = DefaultExecutionManager(
3436
job_id=JOB_ID,
3537
root_dir=str(NOTEBOOK_DIR),
3638
db_url=DB_URL,
3739
staging_paths={"input": str(NOTEBOOK_PATH)},
40+
download_queue=download_manager.queue,
3841
)
3942
manager.add_side_effects_files(str(NOTEBOOK_DIR))
4043

0 commit comments

Comments
 (0)