diff --git a/qsim/core.py b/qsim/core.py index a485aa33..dd5f2eb2 100644 --- a/qsim/core.py +++ b/qsim/core.py @@ -153,7 +153,7 @@ class ThreadSimulator(SimulatorBase): class ProcessSimulator(SimulatorBase): def __init__(self, sources, transforms, client, feed=None, merge=None): - SimlulatorBase.__init__(self, sources, transforms, client, feed, merge) + SimulatorBase.__init__(self, sources, transforms, client, feed, merge) def launch_component(self, name, component): qutil.LOGGER.info("starting {name}".format(name=name)) diff --git a/qsim/test/test_messaging.py b/qsim/test/test_messaging.py index ce8c66e8..ea75a81f 100644 --- a/qsim/test/test_messaging.py +++ b/qsim/test/test_messaging.py @@ -7,7 +7,7 @@ import unittest2 as unittest import multiprocessing import time -from qsim.core import ThreadSimulator, DataFeed +from qsim.core import ThreadSimulator, ProcessSimulator, DataFeed from qsim.transforms.technical import MovingAverage from qsim.sources import RandomEquityTrades import qsim.util as qutil diff --git a/setup.cfg b/setup.cfg index 80aa1c64..3286ce2f 100644 --- a/setup.cfg +++ b/setup.cfg @@ -8,6 +8,7 @@ cover-erase=1 cover-html=1 cover-html-dir=docs/_build/html/cover with-xunit=1 +#processes=2 # Drop into debugger on failure