|
5 | 5 | except ImportError: |
6 | 6 | import os |
7 | 7 | DEVNULL = open(os.devnull, 'wb') |
| 8 | +import os.path |
8 | 9 | import sys |
9 | 10 | import yaml |
10 | 11 | import signal |
@@ -350,13 +351,13 @@ def _send_email(self, title, content): |
350 | 351 | s.connect(self.config['email']['from']['host']) |
351 | 352 | s.login(user=self.config['email']['from']['username'], |
352 | 353 | password=self.config['email']['from']['password']) |
353 | | - s.send_message(msg) |
| 354 | + s.sendmail(msg['From'], msg['To'], msg=msg.as_string()) |
354 | 355 | s.quit() |
355 | 356 |
|
356 | 357 | def _sync_from_stream(self): |
357 | 358 | logging.info("Start to dump from stream") |
358 | 359 | docs = reduce(lambda x, y: y(x), [self._xml_parser, |
359 | | - self._formatter, |
| 360 | + self._formatter, |
360 | 361 | self._mapper, |
361 | 362 | self._processor], |
362 | 363 | self._xml_dump_loader()) |
|
0 commit comments