|
@@ -1,5 +1,6 @@
|
1
|
1
|
# -*- coding: utf-8 -*-
|
2
|
2
|
|
|
3
|
+import os
|
3
|
4
|
import time
|
4
|
5
|
import imaplib
|
5
|
6
|
import json
|
|
@@ -188,9 +189,15 @@ class MailFetcher(object):
|
188
|
189
|
self.token = token
|
189
|
190
|
self.use_html_parsing = use_html_parsing
|
190
|
191
|
self.use_txt_parsing = use_txt_parsing
|
191
|
|
- self.lock = filelock.FileLock(lockfile_path)
|
|
192
|
+ self._set_lock(lockfile_path)
|
192
|
193
|
self._is_active = True
|
193
|
194
|
|
|
195
|
+ def _set_lock(self, lockfile_path):
|
|
196
|
+ dir_path = os.path.dirname(lockfile_path)
|
|
197
|
+ if dir_path:
|
|
198
|
+ os.makedirs(dir_path, exist_ok=True)
|
|
199
|
+ self.lock = filelock.FileLock(lockfile_path)
|
|
200
|
+
|
194
|
201
|
def run(self) -> None:
|
195
|
202
|
logger.info(self, 'Starting MailFetcher')
|
196
|
203
|
while self._is_active:
|