diff --git a/force_bdss/core_plugins/dummy/dummy_dakota/dakota_optimizer.py b/force_bdss/core_plugins/dummy/dummy_dakota/dakota_optimizer.py index 8ceddba8282f9ca32a0c3ceae0ab460c26b4c026..96d5fe70a617c0401f72df5e62555c0d602cd7f6 100644 --- a/force_bdss/core_plugins/dummy/dummy_dakota/dakota_optimizer.py +++ b/force_bdss/core_plugins/dummy/dummy_dakota/dakota_optimizer.py @@ -30,6 +30,7 @@ class DummyDakotaOptimizer(BaseMCO): application = self.factory.plugin.application + self.started = True for value in value_iterator: ps = subprocess.Popen( [sys.argv[0], @@ -45,3 +46,5 @@ class DummyDakotaOptimizer(BaseMCO): 'input': tuple(value), 'output': tuple(out_data) } + + self.finished = True diff --git a/force_bdss/mco/base_mco.py b/force_bdss/mco/base_mco.py index 2c576d26d295a8a128d672662a9b1930aba6d9b1..54bac8d83b4e2cca0a5ebbb2f44b4eb085c0f4e4 100644 --- a/force_bdss/mco/base_mco.py +++ b/force_bdss/mco/base_mco.py @@ -1,8 +1,7 @@ import abc -from traits.api import ABCHasStrictTraits, Instance, Event +from traits.api import ABCHasStrictTraits, Instance, Event, Dict, Str, Tuple -from force_bdss.mco.events import BaseMCOEvent from .i_mco_factory import IMCOFactory @@ -15,10 +14,12 @@ class BaseMCO(ABCHasStrictTraits): factory = Instance(IMCOFactory) #: Triggered when an event occurs. - event = Event(BaseMCOEvent) + started = Event() + + finished = Event() # Event triggered when the mco wants to send new data to listeners - new_data = Event() + new_data = Event(Dict(Str(), Tuple())) def __init__(self, factory, *args, **kwargs): """Initializes the MCO.