run health checks on setup

CHANGELOG.md

@@ -4,10 +4,11 @@
 ### Breaking
 ### Features
 
-* adds readiness check to metrics
+* adds health check endpoint to metrics on path `/health`
 * changes helm chart to use new readiness check
 * adds `healthcheck_timeout` option to all components to tweak the timeout of healthchecks
 * adds `desired_cluster_status` option to opensearch output to signal healthy cluster status
+* initially run health checks on setup for every configured component
 
 
 ### Improvements

logprep/abc/component.py

@@ -98,9 +98,9 @@ def describe(self) -> str:
     def setup(self):
         """Set the component up."""
         self._populate_cached_properties()
-        # while not self.health():
-        #     logger.info("Waiting for %s to be healthy", self.name)
-        #     time.sleep(1)
+        while not self.health():
+            logger.info("Waiting for %s to be healthy", self.name)
+            time.sleep(5)
 
     def _populate_cached_properties(self):
         _ = [

logprep/connector/http/input.py

@@ -438,7 +438,6 @@ def setup(self):
         only runs a single time for multiple processes.
         """
 
-        super().setup()
         if not hasattr(self, "pipeline_index"):
             raise FatalInputError(
                 self, "Necessary instance attribute `pipeline_index` could not be found."
@@ -469,6 +468,7 @@ def setup(self):
             self._config.uvicorn_config, app, daemon=False, logger_name="HTTPServer"
         )
         self.http_server.start()
+        super().setup()
 
     @staticmethod
     def _get_asgi_app(endpoints_config: dict) -> falcon.asgi.App: