Method notify_finished

src/execution/process_base.py:109–116

(self)

        self.finish_listeners.append(listener)

    def notify_finished(self):
        self.wait_finish()

        for listener in self.finish_listeners:
            try:
                listener.finished()
            except:
                LOGGER.exception('Failed to notify listener: ' + str(listener))

    def cleanup(self):
        self.output_stream.dispose()