Merge pull request #191 from mraspaud/fix-hang

Fix call to posttroll publishers' start and stop

setup.py

@@ -36,10 +36,10 @@
     pass
 
 
-install_requires = ['pyyaml', 'dpath', 'trollsift']
+install_requires = ['pyyaml', 'dpath', 'trollsift', 'posttroll>=1.10.0']
 
 if "test" not in sys.argv:
-    install_requires += ['posttroll', 'satpy>=0.32.0', 'pyorbital']
+    install_requires += ['satpy>=0.32.0', 'pyorbital']
 
 NAME = 'trollflow2'
 README = open('README.md', 'r').read()

trollflow2/plugins/__init__.py

@@ -23,7 +23,7 @@
 import datetime as dt
 import os
 import pathlib
-from contextlib import contextmanager, suppress, nullcontext
+from contextlib import contextmanager, nullcontext, suppress
 from logging import getLogger
 from tempfile import NamedTemporaryFile
 from urllib.parse import urlsplit, urlunsplit
@@ -471,14 +471,14 @@ def __setstate__(self, kwargs):
         logger.debug('Starting publisher')
         self.port = kwargs.get('port', 0)
         self.nameservers = kwargs.get('nameservers', "")
-        self._pub_starter = create_publisher_from_dict_config(
+        self.pub = create_publisher_from_dict_config(
             {
                 'port': self.port,
                 'nameservers': self.nameservers,
                 'name': 'l2processor',
             }
         )
-        self.pub = self._pub_starter.start()
+        self.pub.start()
 
     @staticmethod
     def create_message(fmat, mda):