Skip to content

Commit 61eb615

Browse files
+ Pure python integration
1 parent 5657f4a commit 61eb615

File tree

1 file changed

+3
-4
lines changed

1 file changed

+3
-4
lines changed

tests/test_parallelprocessing.py

Lines changed: 3 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -1,5 +1,4 @@
11
import time
2-
import numpy
32
import pytest
43
from src.thread import ParallelProcessing, exceptions
54

@@ -19,7 +18,7 @@ def _dummy_raiseException(x: Exception, delay: float = 0):
1918
# >>>>>>>>>> General Use <<<<<<<<<< #
2019
def test_threadsScaleDown():
2120
"""This test is for testing if threads scale down `max_threads` when the dataset is lesser than the thread count"""
22-
dataset = numpy.arange(0, 2).tolist()
21+
dataset = list(range(0, 2))
2322
new = ParallelProcessing(
2423
function = _dummy_dataProcessor,
2524
dataset = dataset,
@@ -32,7 +31,7 @@ def test_threadsScaleDown():
3231

3332
def test_threadsProcessing():
3433
"""This test is for testing if threads correctly order data in the `dataset` arrangement"""
35-
dataset = numpy.arange(0, 500).tolist()
34+
dataset = list(range(0, 500))
3635
new = ParallelProcessing(
3736
function = _dummy_dataProcessor,
3837
dataset = dataset,
@@ -48,7 +47,7 @@ def test_threadsProcessing():
4847
# >>>>>>>>>> Raising Exceptions <<<<<<<<<< #
4948
def test_raises_StillRunningError():
5049
"""This test should raise ThreadStillRunningError"""
51-
dataset = numpy.arange(0, 8).tolist()
50+
dataset = list(range(0, 8))
5251
new = ParallelProcessing(
5352
function = _dummy_dataProcessor,
5453
dataset = dataset,

0 commit comments

Comments
 (0)