| 170 | return info |
| 171 | |
| 172 | async def run(self): |
| 173 | logger.info(f"| Processing {self.data_type} data from {self.source}...") |
| 174 | tag_name = get_tag_name(assets_name=self.assets_name, |
| 175 | source=self.source, |
| 176 | data_type=self.data_type, |
| 177 | level=self.level) |
| 178 | save_dir = os.path.join(self.workdir, tag_name) |
| 179 | os.makedirs(save_dir, exist_ok=True) |
| 180 | info = await self._process(save_dir = save_dir) |
| 181 | info["tag"] = tag_name |
| 182 | |
| 183 | return info |
| 184 | |
| 185 | @PROCESSOR.register_module(force=True) |
| 186 | class AggProcessor(AbstractProcessor): |