| 1788 | time.sleep(60) |
| 1789 | |
| 1790 | def do_once(self): |
| 1791 | task_file_list = os.listdir(self.task_path) |
| 1792 | for file in task_file_list: |
| 1793 | try: |
| 1794 | filename = '{}/{}'.format(self.task_path, file) |
| 1795 | file_data = read_file(filename) |
| 1796 | if not file_data: |
| 1797 | os.remove(filename) |
| 1798 | continue |
| 1799 | data = json.loads(file_data) |
| 1800 | # 超过执行时间 |
| 1801 | if time.time() > int(data['time']): |
| 1802 | self.proc_run_tasks_list(filename) |
| 1803 | except: |
| 1804 | err = traceback.format_exc() |
| 1805 | write_log("延时任务执行失败", err, _level='ERROR', color='red') |
| 1806 | |
| 1807 | @staticmethod |
| 1808 | def proc_run_tasks_list(filename: str ): |