diff --git a/force_bdss/io/workflow_reader.py b/force_bdss/io/workflow_reader.py index f5dc86a8f61ec1c594f87a6f8904a46fb519c816..1283a86ef05ec7338e3d707e10607165a071feb4 100644 --- a/force_bdss/io/workflow_reader.py +++ b/force_bdss/io/workflow_reader.py @@ -89,7 +89,8 @@ class WorkflowReader(HasStrictTraits): wf.mco = self._extract_mco(wf_data) wf.data_sources[:] = self._extract_data_sources(wf_data) wf.kpi_calculators[:] = self._extract_kpi_calculators(wf_data) - wf.notification_listeners[:] = self._extract_listeners(wf_data) + wf.notification_listeners[:] = \ + self._extract_notification_listeners(wf_data) except KeyError as e: logging.exception("Could not read file") raise InvalidFileException("Could not read file. " diff --git a/force_bdss/tests/fixtures/test_csv.json b/force_bdss/tests/fixtures/test_csv.json index c70795734c8ba06f3d7f746a3121c1399e504506..d9d6e35bbb644d659031530caca14db4f7af3a24 100644 --- a/force_bdss/tests/fixtures/test_csv.json +++ b/force_bdss/tests/fixtures/test_csv.json @@ -70,6 +70,16 @@ ] } } + ], + "notification_listeners": [ + { + "id": "force.bdss.enthought.factory.ui_notification", + "model_data": { + "sync_url": "tcp://127.0.0.1:12346", + "pub_url": "tcp://127.0.0.1:12345", + "identifier": "vfdjlkadfkljfsd" + } + } ] } }