register_all_wrappers
(C)
| 1290 | |
| 1291 | |
| 1292 | def register_all_wrappers(C): |
| 1293 | """register_all_wrappers""" |
| 1294 | logger = get_module_logger("data") |
| 1295 | module = get_module_by_module_path("qlib.data") |
| 1296 | |
| 1297 | _calendar_provider = init_instance_by_config(C.calendar_provider, module) |
| 1298 | if getattr(C, "calendar_cache", None) is not None: |
| 1299 | _calendar_provider = init_instance_by_config(C.calendar_cache, module, provide=_calendar_provider) |
| 1300 | register_wrapper(Cal, _calendar_provider, "qlib.data") |
| 1301 | logger.debug(f"registering Cal {C.calendar_provider}-{C.calendar_cache}") |
| 1302 | |
| 1303 | _instrument_provider = init_instance_by_config(C.instrument_provider, module) |
| 1304 | register_wrapper(Inst, _instrument_provider, "qlib.data") |
| 1305 | logger.debug(f"registering Inst {C.instrument_provider}") |
| 1306 | |
| 1307 | if getattr(C, "feature_provider", None) is not None: |
| 1308 | feature_provider = init_instance_by_config(C.feature_provider, module) |
| 1309 | register_wrapper(FeatureD, feature_provider, "qlib.data") |
| 1310 | logger.debug(f"registering FeatureD {C.feature_provider}") |
| 1311 | |
| 1312 | if getattr(C, "pit_provider", None) is not None: |
| 1313 | pit_provider = init_instance_by_config(C.pit_provider, module) |
| 1314 | register_wrapper(PITD, pit_provider, "qlib.data") |
| 1315 | logger.debug(f"registering PITD {C.pit_provider}") |
| 1316 | |
| 1317 | if getattr(C, "expression_provider", None) is not None: |
| 1318 | # This provider is unnecessary in client provider |
| 1319 | _eprovider = init_instance_by_config(C.expression_provider, module) |
| 1320 | if getattr(C, "expression_cache", None) is not None: |
| 1321 | _eprovider = init_instance_by_config(C.expression_cache, module, provider=_eprovider) |
| 1322 | register_wrapper(ExpressionD, _eprovider, "qlib.data") |
| 1323 | logger.debug(f"registering ExpressionD {C.expression_provider}-{C.expression_cache}") |
| 1324 | |
| 1325 | _dprovider = init_instance_by_config(C.dataset_provider, module) |
| 1326 | if getattr(C, "dataset_cache", None) is not None: |
| 1327 | _dprovider = init_instance_by_config(C.dataset_cache, module, provider=_dprovider) |
| 1328 | register_wrapper(DatasetD, _dprovider, "qlib.data") |
| 1329 | logger.debug(f"registering DatasetD {C.dataset_provider}-{C.dataset_cache}") |
| 1330 | |
| 1331 | register_wrapper(D, C.provider, "qlib.data") |
| 1332 | logger.debug(f"registering D {C.provider}") |
no test coverage detected