(self)
| 337 | logger.info("end of instruments dump.\n") |
| 338 | |
| 339 | def _dump_features(self): |
| 340 | logger.info("start dump features......") |
| 341 | _dump_func = partial(self._dump_bin, calendar_list=self._calendars_list) |
| 342 | with tqdm(total=len(self.df_files)) as p_bar: |
| 343 | with ProcessPoolExecutor(max_workers=self.works) as executor: |
| 344 | for _ in executor.map(_dump_func, self.df_files): |
| 345 | p_bar.update() |
| 346 | |
| 347 | logger.info("end of features dump.\n") |
| 348 | |
| 349 | def dump(self): |
| 350 | self._get_all_date() |