def _abort(self):
        try:
            self._finish()
        except KeyboardInterrupt:
            raise
        except BaseException:
            pass
Call _finish, but eat the exception (if any).
dataset/ETHPy150Open spotify/luigi/luigi/format.py/InputPipeProcessWrapper._abort