()
| 276 | |
| 277 | |
| 278 | def register_rules(): |
| 279 | # Register ruletypes and rules. |
| 280 | pack_dir = cfg.CONF.register.pack |
| 281 | fail_on_failure = not cfg.CONF.register.no_fail_on_failure |
| 282 | |
| 283 | registered_count = 0 |
| 284 | overridden_count = 0 |
| 285 | |
| 286 | try: |
| 287 | LOG.info("=========================================================") |
| 288 | LOG.info("############## Registering rules ########################") |
| 289 | LOG.info("=========================================================") |
| 290 | rule_types_registrar.register_rule_types() |
| 291 | except Exception as e: |
| 292 | LOG.warning("Failed to register rule types: %s", e, exc_info=True) |
| 293 | return |
| 294 | |
| 295 | try: |
| 296 | with Timer(key="st2.register.rules"): |
| 297 | registered_count, overridden_count = rules_registrar.register_rules( |
| 298 | pack_dir=pack_dir, fail_on_failure=fail_on_failure |
| 299 | ) |
| 300 | except Exception as e: |
| 301 | exc_info = not fail_on_failure |
| 302 | LOG.warning("Failed to register rules: %s", e, exc_info=exc_info) |
| 303 | |
| 304 | if fail_on_failure: |
| 305 | raise e |
| 306 | |
| 307 | LOG.info("Registered %s rules.", registered_count) |
| 308 | LOG.info("%s rules had their metadata overridden." % (overridden_count)) |
| 309 | |
| 310 | |
| 311 | def register_aliases(): |
no test coverage detected