We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent db28404 commit 62d6a57Copy full SHA for 62d6a57
tests/buffer/task_scheduler_test.py
@@ -13,7 +13,7 @@
13
from trinity.common.workflows.workflow import Task
14
15
16
-@READER.register_module("custom")
+@READER.register_module("custom_reader")
17
class CustomReader(TaskFileReader):
18
"""A custom reader for testing."""
19
@@ -329,6 +329,7 @@ async def test_task_scheduler_simple(self):
329
config.mode = "explore"
330
config.buffer.batch_size = 4
331
config.buffer.explorer_input.taskset = get_unittest_dataset_config("countdown", "train")
332
+ config.buffer.explorer_input.taskset.storage_type = "custom_reader"
333
config.check_and_update()
334
335
task_scheduler = get_taskset_scheduler({}, config)
0 commit comments