From 7d4d8037a3efeaac471461aeb0f593cc6d260052 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Sebastian=20M=C3=BCller?= <mueller.seb@posteo.de> Date: Mon, 1 Jul 2024 17:38:25 +0200 Subject: [PATCH] remove 'composition.initialize()' from docs --- benchmarks/profiling/profile_huge_memory.py | 1 - benchmarks/profiling/profile_numpy.py | 1 - benchmarks/run/test_run.py | 1 - .../finam-book/development/adapters.rst | 2 -- .../finam-book/development/components.rst | 2 -- .../finam-book/development/connect_phase.rst | 2 -- .../finam-book/development/performance.rst | 1 - .../development/special_components.rst | 2 -- .../finam-book/usage/coupling_scripts.rst | 8 +---- src/finam/schedule.py | 1 - tests/adapters/test_regrid.py | 11 ------- tests/adapters/test_stats.py | 1 - tests/adapters/test_time_integration.py | 2 -- tests/core/test_propagate_info.py | 4 --- tests/core/test_pull_based_component.py | 1 - tests/core/test_schedule.py | 30 ------------------- tests/core/test_sdk.py | 2 -- tests/core/test_units.py | 2 -- tests/data/test_masked.py | 1 - tests/modules/test_callback.py | 1 - tests/modules/test_control.py | 5 ---- tests/modules/test_csv_writer.py | 1 - tests/modules/test_debug.py | 2 -- tests/modules/test_generator.py | 1 - tests/modules/test_noise.py | 9 ------ tests/modules/test_parametric.py | 8 ----- tests/modules/test_simplex_noise.py | 2 -- tests/modules/test_weighted_sum.py | 6 ---- 28 files changed, 1 insertion(+), 109 deletions(-) diff --git a/benchmarks/profiling/profile_huge_memory.py b/benchmarks/profiling/profile_huge_memory.py index cbfed840..6f136d93 100644 --- a/benchmarks/profiling/profile_huge_memory.py +++ b/benchmarks/profiling/profile_huge_memory.py @@ -38,7 +38,6 @@ def run_model(): ) composition = fm.Composition([source, sink], slot_memory_limit=500 * 2**20) - composition.initialize() source["Out"] >> sink["In"] diff --git a/benchmarks/profiling/profile_numpy.py b/benchmarks/profiling/profile_numpy.py index 6027e7d0..d91fb3cb 100644 --- a/benchmarks/profiling/profile_numpy.py +++ b/benchmarks/profiling/profile_numpy.py @@ -49,7 +49,6 @@ def run_model(): ) composition = fm.Composition([source, sink]) - composition.initialize() source["Out"] >> sink["In"] diff --git a/benchmarks/run/test_run.py b/benchmarks/run/test_run.py index 26c56b1d..277e53dc 100644 --- a/benchmarks/run/test_run.py +++ b/benchmarks/run/test_run.py @@ -39,7 +39,6 @@ class SimpleRunBase(unittest.TestCase): ) self.composition = fm.Composition([source, sink]) - self.composition.initialize() source["Out"] >> sink["In"] diff --git a/docs/source/finam-book/development/adapters.rst b/docs/source/finam-book/development/adapters.rst index 92cd5e95..ebe02cc5 100644 --- a/docs/source/finam-book/development/adapters.rst +++ b/docs/source/finam-book/development/adapters.rst @@ -66,7 +66,6 @@ File ``src/scale.py``: adapter = Scale(0.5) comp = fm.Composition([generator, consumer]) - comp.initialize() generator.outputs["Value"] >> adapter >> consumer.inputs["Input"] @@ -235,7 +234,6 @@ In :meth:`.Adapter._get_data`, we can now do the interpolation whenever data is adapter = TimeInterpolation() comp = fm.Composition([generator, consumer]) - comp.initialize() generator.outputs["Value"] >> adapter >> consumer.inputs["Input"] diff --git a/docs/source/finam-book/development/components.rst b/docs/source/finam-book/development/components.rst index 332d84fd..6dd0ffe0 100644 --- a/docs/source/finam-book/development/components.rst +++ b/docs/source/finam-book/development/components.rst @@ -258,7 +258,6 @@ For the tests, we need to set up a real coupling from here on, as the component' # set up a composition composition = fm.Composition([model, generator, consumer], log_level="DEBUG") - composition.initialize() # connect components generator.outputs["A"] >> model.inputs["A"] @@ -424,7 +423,6 @@ Here is the final code of the completed component. step=timedelta(days=7), ) composition = fm.Composition([model, generator, consumer], log_level="DEBUG") - composition.initialize() generator.outputs["A"] >> model.inputs["A"] generator.outputs["B"] >> model.inputs["B"] diff --git a/docs/source/finam-book/development/connect_phase.rst b/docs/source/finam-book/development/connect_phase.rst index fed7eda6..bf1340dd 100644 --- a/docs/source/finam-book/development/connect_phase.rst +++ b/docs/source/finam-book/development/connect_phase.rst @@ -191,7 +191,6 @@ In the most simple case, all metadata is known in :meth:`.Component._initialize` ) comp = fm.Composition([generator, simple_conn, consumer]) - comp.initialize() generator.outputs["Output1"] >> simple_conn.inputs["A"] generator.outputs["Output2"] >> simple_conn.inputs["B"] @@ -284,7 +283,6 @@ and the initial data should be generated from it. ) comp = fm.Composition([generator, complex_conn, consumer]) - comp.initialize() generator.outputs["Output1"] >> complex_conn.inputs["A"] generator.outputs["Output2"] >> complex_conn.inputs["B"] diff --git a/docs/source/finam-book/development/performance.rst b/docs/source/finam-book/development/performance.rst index 55f72d81..adebcec9 100644 --- a/docs/source/finam-book/development/performance.rst +++ b/docs/source/finam-book/development/performance.rst @@ -123,7 +123,6 @@ Both properties can also be set for individual :class:`.Output` and :class:`.Ada .. testcode:: memory-limit comp = finam.Composition([comp_a, comp_b]) - comp.initialize() comp_a.outputs["Noise"].memory_limit = 256 * 2**20, # 256MB doctest: +ELLIPSIS diff --git a/docs/source/finam-book/development/special_components.rst b/docs/source/finam-book/development/special_components.rst index 17b52a4b..f11571e6 100644 --- a/docs/source/finam-book/development/special_components.rst +++ b/docs/source/finam-book/development/special_components.rst @@ -78,7 +78,6 @@ Push-based components can use :class:`.CallbackInput` to get informed about inco push_comp = PushComponent() comp = fm.Composition([generator, push_comp]) - comp.initialize() generator.outputs["Value"] >> push_comp.inputs["Input"] @@ -153,7 +152,6 @@ Push-based components can use :class:`.CallbackOutput` to intercept data pulls. ) comp = fm.Composition([pull_comp, consumer]) - comp.initialize() pull_comp.outputs["Output"] >> consumer.inputs["Input"] diff --git a/docs/source/finam-book/usage/coupling_scripts.rst b/docs/source/finam-book/usage/coupling_scripts.rst index b3b03e97..3fb75baf 100644 --- a/docs/source/finam-book/usage/coupling_scripts.rst +++ b/docs/source/finam-book/usage/coupling_scripts.rst @@ -36,9 +36,6 @@ Here is a simple example coupling two components: # Create a `Composition` containing all components composition = fm.Composition([generator, consumer]) - # Initialize the `Composition` - composition.initialize() - # Couple inputs to outputs generator.outputs["Noise"] >> consumer.inputs["Value"] @@ -63,7 +60,7 @@ Note: The typical steps in a script are: #. Instantiate components and adapters (see next example) -#. Create a :class:`.Composition` and initialize it +#. Create a :class:`.Composition` #. Connect outputs to inputs using the overloaded ``>>`` operator (:meth:`.IOutput.__rshift__`) #. Run the :class:`.Composition` @@ -133,9 +130,6 @@ time steps and an adapter: # Create a `Composition` containing all components composition = fm.Composition([generator, consumer_1, consumer_2]) - # Initialize the `Composition` - composition.initialize() - # Couple inputs to outputs, without an adapter ( generator.outputs["Noise"] diff --git a/src/finam/schedule.py b/src/finam/schedule.py index 46056efa..ba4d79a7 100644 --- a/src/finam/schedule.py +++ b/src/finam/schedule.py @@ -55,7 +55,6 @@ class Composition(Loggable): comp_b = AnotherComponent(...) composition = Composition([comp_a, comp_b]) - composition.initialize() comp_b.outputs["Out"] >> SomeAdapter() >> comp_b.inputs["In"] diff --git a/tests/adapters/test_regrid.py b/tests/adapters/test_regrid.py index c3045936..eef59c9e 100644 --- a/tests/adapters/test_regrid.py +++ b/tests/adapters/test_regrid.py @@ -57,7 +57,6 @@ class TestRegrid(unittest.TestCase): ) composition = Composition([source, sink], log_level="DEBUG") - composition.initialize() (source.outputs["Output"] >> RegridNearest() >> sink.inputs["Input"]) @@ -108,7 +107,6 @@ class TestRegrid(unittest.TestCase): ) composition = Composition([source, sink], log_level="DEBUG") - composition.initialize() (source.outputs["Output"] >> RegridNearest() >> sink.inputs["Input"]) @@ -153,7 +151,6 @@ class TestRegrid(unittest.TestCase): ) composition = Composition([source, sink]) - composition.initialize() (source.outputs["Output"] >> RegridNearest() >> sink.inputs["Input"]) @@ -197,7 +194,6 @@ class TestRegrid(unittest.TestCase): ) composition = Composition([source, sink]) - composition.initialize() (source.outputs["Output"] >> RegridLinear() >> sink.inputs["Input"]) @@ -245,7 +241,6 @@ class TestRegrid(unittest.TestCase): ) composition = Composition([source, sink], log_level="DEBUG") - composition.initialize() ( source.outputs["Output"] @@ -288,7 +283,6 @@ class TestRegrid(unittest.TestCase): ) composition = Composition([source, sink]) - composition.initialize() ( source.outputs["Output"] @@ -333,7 +327,6 @@ class TestRegrid(unittest.TestCase): ) composition = Composition([source, sink]) - composition.initialize() ( source.outputs["Output"] @@ -377,7 +370,6 @@ class TestRegrid(unittest.TestCase): ) composition = Composition([source, sink]) - composition.initialize() (source.outputs["Output"] >> RegridLinear() >> sink.inputs["Input"]) @@ -424,7 +416,6 @@ class TestRegrid(unittest.TestCase): regrid = RegridLinear() composition = Composition([source, sink_1, sink_2]) - composition.initialize() source.outputs["Output"] >> regrid regrid >> sink_1.inputs["Input"] @@ -479,7 +470,6 @@ class TestRegrid(unittest.TestCase): regrid = RegridLinear() composition = Composition([source, sink_1, sink_2]) - composition.initialize() source.outputs["Output"] >> regrid regrid >> sink_1.inputs["Input"] @@ -530,7 +520,6 @@ class TestRegrid(unittest.TestCase): ) composition = Composition([source, sink]) - composition.initialize() ( source.outputs["Output"] diff --git a/tests/adapters/test_stats.py b/tests/adapters/test_stats.py index 93905792..6d689aea 100644 --- a/tests/adapters/test_stats.py +++ b/tests/adapters/test_stats.py @@ -24,7 +24,6 @@ class TestHistogram(unittest.TestCase): ) composition = fm.Composition([source, sink]) - composition.initialize() ( source.outputs["Noise"] diff --git a/tests/adapters/test_time_integration.py b/tests/adapters/test_time_integration.py index 088860c5..624f7da0 100644 --- a/tests/adapters/test_time_integration.py +++ b/tests/adapters/test_time_integration.py @@ -196,7 +196,6 @@ class TestSumOverTime(unittest.TestCase): ) self.comp = fm.Composition([self.source, self.consumer]) - self.comp.initialize() self.source["Step"] >> self.adapter_lin >> self.consumer["In_lin"] self.source["Step"] >> self.adapter_00 >> self.consumer["In_00"] @@ -284,7 +283,6 @@ class TestAbsSumOverTime(unittest.TestCase): ) self.comp = fm.Composition([self.source, self.consumer]) - self.comp.initialize() self.source["Step"] >> self.adapter_lin >> self.consumer["In_lin"] self.source["Step"] >> self.adapter_00 >> self.consumer["In_00"] diff --git a/tests/core/test_propagate_info.py b/tests/core/test_propagate_info.py index 10d24141..e178058e 100644 --- a/tests/core/test_propagate_info.py +++ b/tests/core/test_propagate_info.py @@ -102,7 +102,6 @@ class TestPropagate(unittest.TestCase): ) composition = Composition([source, sink]) - composition.initialize() (source.outputs["Output"] >> SpecAdapter() >> sink.inputs["Input"]) @@ -131,7 +130,6 @@ class TestPropagate(unittest.TestCase): ) composition = Composition([source, sink]) - composition.initialize() source.outputs["Output"] >> sink.inputs["Input"] @@ -156,7 +154,6 @@ class TestPropagate(unittest.TestCase): ) composition = Composition([source, sink]) - composition.initialize() source.outputs["Output"] >> sink.inputs["Input"] @@ -183,7 +180,6 @@ class TestPropagate(unittest.TestCase): ) composition = Composition([source, sink]) - composition.initialize() source.outputs["Output"] >> sink.inputs["Input"] diff --git a/tests/core/test_pull_based_component.py b/tests/core/test_pull_based_component.py index 72666718..0dcca3da 100644 --- a/tests/core/test_pull_based_component.py +++ b/tests/core/test_pull_based_component.py @@ -49,7 +49,6 @@ class TestPullBasedComponent(unittest.TestCase): ) composition = fm.Composition([pull_comp, consumer], log_level="DEBUG") - composition.initialize() pull_comp.outputs["Out"] >> consumer.inputs["In"] diff --git a/tests/core/test_schedule.py b/tests/core/test_schedule.py index aa906ced..29eaeb44 100644 --- a/tests/core/test_schedule.py +++ b/tests/core/test_schedule.py @@ -187,7 +187,6 @@ class TestComposition(unittest.TestCase): def test_init(self): module = MockupComponent(callbacks={"Output": lambda t: t}, step=timedelta(1.0)) composition = Composition([module]) - composition.initialize() self.assertEqual(module.status, ComponentStatus.INITIALIZED) self.assertEqual(len(module.outputs), 1) @@ -199,7 +198,6 @@ class TestComposition(unittest.TestCase): def test_validate_branching(self): module = MockupComponent(callbacks={"Output": lambda t: t}, step=timedelta(1.0)) composition = Composition([module]) - composition.initialize() non_branching_adapter = ( module.outputs["Output"] @@ -278,7 +276,6 @@ class TestComposition(unittest.TestCase): step=timedelta(days=1), ) composition = Composition([module]) - composition.initialize() with self.assertRaises(FinamConnectError) as context: composition._validate_composition() @@ -297,7 +294,6 @@ class TestComposition(unittest.TestCase): composition = Composition( [module2, module1], log_level=logging.DEBUG, log_file=log_file ) - composition.initialize() module1.outputs["Output"] >> module2.inputs["Input"] @@ -316,7 +312,6 @@ class TestComposition(unittest.TestCase): module2 = MockupDependentComponent(step=timedelta(1.0)) composition = Composition([module2, module1]) - composition.initialize() ada = fm.adapters.Scale(1.0) module1.outputs["Output"] >> ada >> module2.inputs["Input"] @@ -330,7 +325,6 @@ class TestComposition(unittest.TestCase): callbacks={"Output": lambda t: t}, step=timedelta(1.0) ) composition = Composition([module1]) - composition.initialize() with self.assertRaises(ValueError): composition.run(start_time=0, end_time=100) @@ -340,17 +334,14 @@ class TestComposition(unittest.TestCase): callbacks={"Output": lambda t: t}, step=timedelta(1.0) ) composition = Composition([module1]) - composition.initialize() with self.assertRaises(FinamStatusError): - composition.initialize() def test_fail_double_connect(self): module1 = MockupComponent( callbacks={"Output": lambda t: t}, step=timedelta(1.0) ) composition = Composition([module1]) - composition.initialize() composition.connect(datetime(2000, 1, 1)) with self.assertRaises(FinamStatusError): @@ -367,7 +358,6 @@ class TestComposition(unittest.TestCase): module2 = MockupDependentComponent(step=timedelta(1.0)) composition = Composition([module2, module1]) - composition.initialize() module1.outputs["Output"] >> module2.inputs["Input"] @@ -381,7 +371,6 @@ class TestComposition(unittest.TestCase): module3 = MockupDependentComponent(step=timedelta(1.0)) composition = Composition([module3, module2, module1]) - composition.initialize() module1.outputs["Output"] >> module2.inputs["Input"] module2.outputs["Output"] >> module3.inputs["Input"] @@ -395,7 +384,6 @@ class TestComposition(unittest.TestCase): module2 = MockupDependentComponent(step=timedelta(1.0)) composition = Composition([module2, module1]) - composition.initialize() module1.outputs["Output"] >> Scale(1.0) >> module2.inputs["Input"] @@ -408,7 +396,6 @@ class TestComposition(unittest.TestCase): module2 = MockupDependentComponent(step=timedelta(1.0)) composition = Composition([module2, module1]) - composition.initialize() module1.outputs["Output"] >> Scale(1.0) >> Scale(1.0) >> module2.inputs["Input"] @@ -419,7 +406,6 @@ class TestComposition(unittest.TestCase): module2 = MockupCircularComponent(step=timedelta(1.0)) composition = Composition([module1, module2]) - composition.initialize() module1.outputs["Output"] >> module2.inputs["Input"] module2.outputs["Output"] >> module1.inputs["Input"] @@ -433,7 +419,6 @@ class TestComposition(unittest.TestCase): module = NoTimeComponent() composition = Composition([module]) - composition.initialize() with self.assertRaises(ValueError): composition.run(end_time=datetime(2000, 1, 31)) @@ -444,7 +429,6 @@ class TestComposition(unittest.TestCase): module = MockupComponent(callbacks={"Output": lambda t: t}, step=timedelta(1.0)) composition = Composition([module]) - composition.initialize() with self.assertRaises(ValueError): composition.run(end_time=None) @@ -459,7 +443,6 @@ class TestComposition(unittest.TestCase): callbacks={"Output": lambda t: 1.0}, step=timedelta(days=31) ) composition = Composition([module1, module2]) - composition.initialize() composition.run(start_time=datetime(2000, 1, 1), end_time=datetime(2000, 1, 1)) def test_missing_component_upstream(self): @@ -469,7 +452,6 @@ class TestComposition(unittest.TestCase): module2 = MockupDependentComponent(step=timedelta(1.0)) composition = Composition([module2]) - composition.initialize() module1.outputs["Output"] >> Scale(1.0) >> Scale(1.0) >> module2.inputs["Input"] @@ -485,7 +467,6 @@ class TestComposition(unittest.TestCase): module2 = MockupDependentComponent(step=timedelta(1.0)) composition = Composition([module1]) - composition.initialize() module1.outputs["Output"] >> Scale(1.0) >> Scale(1.0) >> module2.inputs["Input"] @@ -499,7 +480,6 @@ class TestComposition(unittest.TestCase): module2 = MockupDependentComponent(step=timedelta(1.0)) composition = Composition([module1, module2]) - composition.initialize() module1.outputs["Output"] >> Scale(1.0) >> module2.inputs["Input"] @@ -534,7 +514,6 @@ class TestComposition(unittest.TestCase): module4 = MockupDependentComponent(step=timedelta(1.0)) composition = Composition([module1, module2, module3, module4]) - composition.initialize() module1.outputs["Output"] >> Scale(1.0) >> module2.inputs["Input"] module1.outputs["Output"] >> Scale(1.0) >> module3.inputs["Input"] @@ -596,7 +575,6 @@ class TestComposition(unittest.TestCase): ) composition = Composition([source, sink]) - composition.initialize() source.outputs["Noise"] >> Scale(1.0) >> sink.inputs["In"] @@ -615,7 +593,6 @@ class TestComposition(unittest.TestCase): sink = MockupDependentComponent(step=timedelta(days=1), static=True) composition = Composition([source, sink]) - composition.initialize() source.outputs["Noise"] >> Scale(1.0) >> sink.inputs["Input"] @@ -668,7 +645,6 @@ class TestComposition(unittest.TestCase): step=timedelta(days=8), ) composition = Composition([module1, module2, module3]) - composition.initialize() module1.outputs["Out"] >> Scale(1.0) >> module2.inputs["In"] module2.outputs["Out"] >> Scale(1.0) >> module3.inputs["In"] @@ -732,7 +708,6 @@ class TestComposition(unittest.TestCase): step=timedelta(days=1), ) composition = Composition([module1, module2]) - composition.initialize() module1.outputs["Out"] >> Scale(1.0) >> module2.inputs["In"] @@ -795,7 +770,6 @@ class TestComposition(unittest.TestCase): step=timedelta(days=1), ) composition = Composition([module1, module2]) - composition.initialize() module1.outputs["Out1"] >> Scale(1.0) >> module2.inputs["In1"] module1.outputs["Out2"] >> Scale(1.0) >> module2.inputs["In2"] @@ -845,7 +819,6 @@ class TestComposition(unittest.TestCase): initial_pull=False, ) composition = Composition([module1, module2]) - composition.initialize() module1.outputs["Out"] >> Scale(1.0) >> module2.inputs["In"] module2.outputs["Out"] >> Scale(1.0) >> module1.inputs["In"] @@ -898,7 +871,6 @@ class TestComposition(unittest.TestCase): ) composition = Composition([module1, module2, module3]) - composition.initialize() module1.outputs["Out"] >> Scale(1.0) >> module2.inputs["In"] module1.outputs["Out"] >> Scale(1.0) >> module3.inputs["A"] @@ -954,7 +926,6 @@ class TestComposition(unittest.TestCase): ) composition = Composition([module1, module2, module3]) - composition.initialize() module1.outputs["Out"] >> Scale(1.0) >> module2.inputs["In"] module1.outputs["Out"] >> Scale(1.0) >> module3.inputs["A"] @@ -975,7 +946,6 @@ class TestComposition(unittest.TestCase): module3 = MockupDependentComponent(step=timedelta(1.0)) composition = Composition([module2, module1, module3]) - composition.initialize() ada1 = fm.adapters.Scale(1.0) ada2 = fm.adapters.Scale(1.0) diff --git a/tests/core/test_sdk.py b/tests/core/test_sdk.py index f4140f78..f89b6bcb 100644 --- a/tests/core/test_sdk.py +++ b/tests/core/test_sdk.py @@ -91,12 +91,10 @@ class TestComponent(unittest.TestCase): composition = Composition([component]) with self.assertRaises(FinamStatusError): - composition.initialize() def test_connect_helper(self): component = MockupComponentIO() composition = Composition([component]) - composition.initialize() component.create_connector() diff --git a/tests/core/test_units.py b/tests/core/test_units.py index 08dc807d..223ef5ba 100644 --- a/tests/core/test_units.py +++ b/tests/core/test_units.py @@ -76,7 +76,6 @@ class TestUnits(unittest.TestCase): sink = MockupConsumer(datetime(2000, 1, 1), UNITS.kilometer) composition = Composition([source, sink]) - composition.initialize() (source.outputs["Output"] >> sink.inputs["Input"]) @@ -109,7 +108,6 @@ class TestUnits(unittest.TestCase): sink = MockupConsumer(datetime(2000, 1, 1), UNITS.seconds) composition = Composition([source, sink]) - composition.initialize() (source.outputs["Output"] >> sink.inputs["Input"]) diff --git a/tests/data/test_masked.py b/tests/data/test_masked.py index e5487e34..464c2d46 100644 --- a/tests/data/test_masked.py +++ b/tests/data/test_masked.py @@ -50,7 +50,6 @@ class TestMasked(unittest.TestCase): ) composition = fm.Composition([source, sink]) - composition.initialize() source.outputs["Output"] >> fm.adapters.Scale(scale=2.0) >> sink.inputs["Input"] composition.connect() diff --git a/tests/modules/test_callback.py b/tests/modules/test_callback.py index bb865bf7..f462c574 100644 --- a/tests/modules/test_callback.py +++ b/tests/modules/test_callback.py @@ -47,7 +47,6 @@ class TestCallback(unittest.TestCase): ) composition = Composition([source, trans, consumer]) - composition.initialize() _ = source.outputs["Out1"] >> trans.inputs["In1"] _ = trans.outputs["Out1"] >> consumer.inputs["In1"] diff --git a/tests/modules/test_control.py b/tests/modules/test_control.py index b84ebf01..6c064d57 100644 --- a/tests/modules/test_control.py +++ b/tests/modules/test_control.py @@ -26,7 +26,6 @@ class TestTimeTrigger(unittest.TestCase): ) composition = fm.Composition([source, trigger, sink]) - composition.initialize() source.outputs["Noise"] >> trigger.inputs["In"] trigger.outputs["Out"] >> sink.inputs["Input"] @@ -66,7 +65,6 @@ class TestTimeTrigger(unittest.TestCase): ) composition = fm.Composition([source, trigger, sink]) - composition.initialize() source.outputs["Out"] >> trigger.inputs["In"] trigger.outputs["Out"] >> sink.inputs["Input"] @@ -109,7 +107,6 @@ class TestTimeTrigger(unittest.TestCase): ) composition = fm.Composition([source, trigger, sink]) - composition.initialize() source.outputs["Out"] >> trigger.inputs["In"] trigger.outputs["Out"] >> sink.inputs["Input"] @@ -143,7 +140,6 @@ class TestTimeTrigger(unittest.TestCase): ) composition = fm.Composition([source, trigger, sink]) - composition.initialize() source.outputs["Noise"] >> trigger.inputs["In"] trigger.outputs["Out"] >> sink.inputs["Input"] @@ -178,7 +174,6 @@ class TestTimeTrigger(unittest.TestCase): ) composition = fm.Composition([source, trigger, sink]) - composition.initialize() source.outputs["Noise"] >> trigger.inputs["In"] trigger.outputs["Out"] >> sink.inputs["Input"] diff --git a/tests/modules/test_csv_writer.py b/tests/modules/test_csv_writer.py index 8f7b5908..b200f482 100644 --- a/tests/modules/test_csv_writer.py +++ b/tests/modules/test_csv_writer.py @@ -37,7 +37,6 @@ class TestCsvWriter(unittest.TestCase): ) comp = Composition([generator, writer]) - comp.initialize() generator.outputs["A"] >> writer.inputs["A"] generator.outputs["B"] >> writer.inputs["B"] diff --git a/tests/modules/test_debug.py b/tests/modules/test_debug.py index 09bd12cc..7140e682 100644 --- a/tests/modules/test_debug.py +++ b/tests/modules/test_debug.py @@ -48,7 +48,6 @@ class TestScheduleLogger(unittest.TestCase): ) composition = fm.Composition([module1, module2, module3, schedule]) - composition.initialize() module1.outputs["Out"] >> fm.adapters.Scale(1.0) >> module2.inputs["In"] module2.outputs["Out"] >> fm.adapters.Scale(1.0) >> module3.inputs["In"] @@ -82,7 +81,6 @@ class TestPushDebugConsumer(unittest.TestCase): ) composition = fm.Composition([module1, consumer]) - composition.initialize() module1.outputs["Out"] >> consumer.inputs["In"] diff --git a/tests/modules/test_generator.py b/tests/modules/test_generator.py index db2f14b1..cada5a39 100644 --- a/tests/modules/test_generator.py +++ b/tests/modules/test_generator.py @@ -28,7 +28,6 @@ class TestStaticCallbackGenerator(unittest.TestCase): ) composition = Composition([source, consumer]) - composition.initialize() _ = source.outputs["Out1"] >> fm.adapters.Scale(2.0) >> consumer.inputs["In1"] diff --git a/tests/modules/test_noise.py b/tests/modules/test_noise.py index bc1d7f1a..1366134f 100644 --- a/tests/modules/test_noise.py +++ b/tests/modules/test_noise.py @@ -28,7 +28,6 @@ class TestNoise(unittest.TestCase): ) composition = fm.Composition([source, trigger, sink]) - composition.initialize() source.outputs["Noise"] >> trigger.inputs["In"] trigger.outputs["Out"] >> sink.inputs["Input"] @@ -60,7 +59,6 @@ class TestNoise(unittest.TestCase): ) composition = fm.Composition([source, trigger, sink]) - composition.initialize() source.outputs["Noise"] >> trigger.inputs["In"] trigger.outputs["Out"] >> sink.inputs["Input"] @@ -92,7 +90,6 @@ class TestNoise(unittest.TestCase): ) composition = fm.Composition([source, trigger, sink]) - composition.initialize() source.outputs["Noise"] >> trigger.inputs["In"] trigger.outputs["Out"] >> sink.inputs["Input"] @@ -124,7 +121,6 @@ class TestNoise(unittest.TestCase): ) composition = fm.Composition([source, trigger, sink]) - composition.initialize() source.outputs["Noise"] >> trigger.inputs["In"] trigger.outputs["Out"] >> sink.inputs["Input"] @@ -156,7 +152,6 @@ class TestNoise(unittest.TestCase): ) composition = fm.Composition([source, trigger, sink]) - composition.initialize() source.outputs["Noise"] >> trigger.inputs["In"] trigger.outputs["Out"] >> sink.inputs["Input"] @@ -188,7 +183,6 @@ class TestNoise(unittest.TestCase): ) composition = fm.Composition([source, trigger, sink]) - composition.initialize() source.outputs["Noise"] >> trigger.inputs["In"] trigger.outputs["Out"] >> sink.inputs["Input"] @@ -220,7 +214,6 @@ class TestNoise(unittest.TestCase): ) composition = fm.Composition([source, trigger, sink]) - composition.initialize() source.outputs["Noise"] >> trigger.inputs["In"] trigger.outputs["Out"] >> sink.inputs["Input"] @@ -252,7 +245,6 @@ class TestNoise(unittest.TestCase): ) composition = fm.Composition([source, trigger, sink]) - composition.initialize() source.outputs["Noise"] >> trigger.inputs["In"] trigger.outputs["Out"] >> sink.inputs["Input"] @@ -293,7 +285,6 @@ class TestStaticNoise(unittest.TestCase): ) composition = fm.Composition([source, sink]) - composition.initialize() source.outputs["Noise"] >> sink.inputs["Input"] diff --git a/tests/modules/test_parametric.py b/tests/modules/test_parametric.py index c494c397..10a8ac5a 100644 --- a/tests/modules/test_parametric.py +++ b/tests/modules/test_parametric.py @@ -32,7 +32,6 @@ class TestParametricGrid(unittest.TestCase): ) composition = fm.Composition([source, trigger, sink]) - composition.initialize() source.outputs["Grid"] >> trigger.inputs["In"] trigger.outputs["Out"] >> sink.inputs["Input"] @@ -68,7 +67,6 @@ class TestParametricGrid(unittest.TestCase): ) composition = fm.Composition([source, trigger, sink]) - composition.initialize() source.outputs["Grid"] >> trigger.inputs["In"] trigger.outputs["Out"] >> sink.inputs["Input"] @@ -106,7 +104,6 @@ class TestParametricGrid(unittest.TestCase): ) composition = fm.Composition([source, trigger, sink]) - composition.initialize() source.outputs["Grid"] >> trigger.inputs["In"] trigger.outputs["Out"] >> sink.inputs["Input"] @@ -141,7 +138,6 @@ class TestParametricGrid(unittest.TestCase): ) composition = fm.Composition([source, trigger, sink]) - composition.initialize() source.outputs["Grid"] >> trigger.inputs["In"] trigger.outputs["Out"] >> sink.inputs["Input"] @@ -177,7 +173,6 @@ class TestParametricGrid(unittest.TestCase): ) composition = fm.Composition([source, trigger, sink]) - composition.initialize() source.outputs["Grid"] >> trigger.inputs["In"] trigger.outputs["Out"] >> sink.inputs["Input"] @@ -213,7 +208,6 @@ class TestParametricGrid(unittest.TestCase): ) composition = fm.Composition([source, trigger, sink]) - composition.initialize() source.outputs["Grid"] >> trigger.inputs["In"] trigger.outputs["Out"] >> sink.inputs["Input"] @@ -251,7 +245,6 @@ class TestParametricGrid(unittest.TestCase): ) composition = fm.Composition([source, trigger, sink]) - composition.initialize() source.outputs["Grid"] >> trigger.inputs["In"] trigger.outputs["Out"] >> sink.inputs["Input"] @@ -280,7 +273,6 @@ class TestStaticParametricGrid(unittest.TestCase): ) composition = fm.Composition([source, sink]) - composition.initialize() source.outputs["Grid"] >> sink.inputs["Input"] diff --git a/tests/modules/test_simplex_noise.py b/tests/modules/test_simplex_noise.py index 96fa77c8..ea3f2af9 100644 --- a/tests/modules/test_simplex_noise.py +++ b/tests/modules/test_simplex_noise.py @@ -20,7 +20,6 @@ class TestSimplexNoise(unittest.TestCase): ) composition = fm.Composition([source, consumer]) - composition.initialize() _ = source.outputs["Noise"] >> consumer.inputs["Noise"] @@ -43,7 +42,6 @@ class TestSimplexNoise(unittest.TestCase): ) composition = fm.Composition([source, consumer]) - composition.initialize() _ = source.outputs["Noise"] >> consumer.inputs["Noise"] diff --git a/tests/modules/test_weighted_sum.py b/tests/modules/test_weighted_sum.py index e3df4046..d934bb2b 100644 --- a/tests/modules/test_weighted_sum.py +++ b/tests/modules/test_weighted_sum.py @@ -52,7 +52,6 @@ class TestWeightedSum(unittest.TestCase): ) composition = fm.Composition([generator1, generator2, merger, consumer]) - composition.initialize() generator1.outputs["Value"] >> merger.inputs["In1"] generator1.outputs["Weight"] >> merger.inputs["In1_weight"] @@ -111,7 +110,6 @@ class TestWeightedSum(unittest.TestCase): ) composition = fm.Composition([generator1, generator2, merger, consumer]) - composition.initialize() generator1.outputs["Value"] >> merger.inputs["In1"] generator1.outputs["Weight"] >> merger.inputs["In1_weight"] @@ -170,7 +168,6 @@ class TestWeightedSum(unittest.TestCase): ) composition = fm.Composition([generator1, generator2, merger, consumer]) - composition.initialize() generator1.outputs["Value"] >> merger.inputs["In1"] generator1.outputs["Weight"] >> merger.inputs["In1_weight"] @@ -226,7 +223,6 @@ class TestWeightedSum(unittest.TestCase): ) composition = fm.Composition([generator1, generator2, merger, consumer]) - composition.initialize() generator1.outputs["Value"] >> merger.inputs["In1"] generator1.outputs["Weight"] >> merger.inputs["In1_weight"] @@ -281,7 +277,6 @@ class TestWeightedSum(unittest.TestCase): ) composition = fm.Composition([generator1, generator2, merger, consumer]) - composition.initialize() generator1.outputs["Value"] >> merger.inputs["In1"] generator1.outputs["Weight"] >> merger.inputs["In1_weight"] @@ -336,7 +331,6 @@ class TestWeightedSum(unittest.TestCase): ) composition = fm.Composition([generator1, generator2, merger, consumer]) - composition.initialize() generator1.outputs["Value"] >> merger.inputs["In1"] generator1.outputs["Weight"] >> merger.inputs["In1_weight"] -- GitLab