Skip to content

Commit c7a4ff9

Browse files
authored
Merge pull request #3 from mraspaud/fix-premature-subscriber-close
Fix premature closing of the subscriber
2 parents e694c10 + 308ab99 commit c7a4ff9

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

pytroll_runner/__init__.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -109,7 +109,7 @@ def run_from_new_subscriber(command, subscriber_settings):
109109
"""Run the command with files gotten from a new subscriber."""
110110
logger.debug("Run from new subscriber...")
111111
with closing(create_subscriber_from_dict_config(subscriber_settings)) as sub:
112-
return run_on_messages(command, sub.recv())
112+
yield from run_on_messages(command, sub.recv())
113113

114114

115115
def run_on_messages(command, messages):

0 commit comments

Comments
 (0)