Closed felipeZ closed 5 years ago
The previous Warning is now an error in python 3.7. The following error is reported:
Traceback (most recent call last):
File "miniconda3/envs/py37/lib/python3.7/site-packages/noodles/lib/streams.py", line 163, in map
sink.send(self.f(x))
StopIteration
The above exception was the direct cause of the following exception:
Traceback (most recent call last):
File "test.py", line 46, in <module>
test()
File "test.py", line 42, in test
return run(c)
File "test.py", line 13, in run
db_file=cache, always_cache=False, echo_log=False)
File "/home/felipe/miniconda3/envs/py37/lib/python3.7/site-packages/noodles/run/threading/sqlite3.py", line 108, in run_parallel
result = scheduler.run(parallel_sqlite_worker, get_workflow(workflow))
File "/home/felipe/miniconda3/envs/py37/lib/python3.7/site-packages/noodles/run/scheduler.py", line 155, in run
sink.send(EndOfQueue)
RuntimeError: generator raised StopIteration
This is fixed in master
Running a workflow using the
run_parallel
function fromfrom noodles.run.threading.sqlite3 import run_parallel
, results in the following warning:A minimal examples, is provided below: