testing parallel processing on longer BaseConcatDatasets
@@ -61,8 +61,9 @@ def test_windows_from_events_preload_false(lazy_loadable_dataset):
def test_windows_from_events_n_jobs(lazy_loadable_dataset):
+ longer_dataset = BaseConcatDataset([lazy_loadable_dataset.datasets[0]] * 8)
windows = [create_windows_from_events(
- concat_ds=lazy_loadable_dataset, trial_start_offset_samples=0,
+ concat_ds=longer_dataset, trial_start_offset_samples=0,
trial_stop_offset_samples=0, window_size_samples=100,
window_stride_samples=100, drop_last_window=False, preload=True,
n_jobs=n_jobs) for n_jobs in [1, 2]]
@@ -324,8 +325,9 @@ def test_fixed_length_windower(start_offset_samples, window_size_samples,
def test_fixed_length_windower_n_jobs(lazy_loadable_dataset):
+ longer_dataset = BaseConcatDataset([lazy_loadable_dataset.datasets[0]] * 8)
windows = [create_fixed_length_windows(
- concat_ds=lazy_loadable_dataset, start_offset_samples=0,
+ concat_ds=longer_dataset, start_offset_samples=0,
stop_offset_samples=None, window_size_samples=100,
window_stride_samples=100, drop_last_window=True, preload=True,
n_jobs=n_jobs) for n_jobs in [1, 2]]
