diff --git a/src/finam/schedule.py b/src/finam/schedule.py index 1025c0fe43ebad634c84b64960ec0ed259a1a1ff..46056efa56f9bce499ab51a7af6dcb73dd29a8d9 100644 --- a/src/finam/schedule.py +++ b/src/finam/schedule.py @@ -9,6 +9,7 @@ Composition :noindex: Composition """ + import logging import os import sys @@ -123,7 +124,6 @@ class Composition(Loggable): self._dependencies = None self._input_owners = None self._output_owners = None - self._is_initialized = False self._is_connected = False self._time_frame = (None, None) @@ -131,14 +131,8 @@ class Composition(Loggable): self._slot_memory_limit = slot_memory_limit self._slot_memory_location = slot_memory_location - def initialize(self): - """Initialize all modules. - - After the call, module inputs and outputs are available for linking. - """ + # initialize self.logger.info("init composition") - if self._is_initialized: - raise FinamStatusError("Composition was already initialized.") for mod in self._modules: self._check_status(mod, [ComponentStatus.CREATED]) @@ -163,8 +157,6 @@ class Composition(Loggable): self._check_status(mod, [ComponentStatus.INITIALIZED]) - self._is_initialized = True - def connect(self, start_time=None): """Performs the connect and validate phases of the composition