FIX RUNNER #100 - Streamable ingestion logs to log versions (#24891)

* FIX RUNNER #100 - Streamable ingestion logs to log versions

* lazy init

Author: pmbrull

ingestion/src/metadata/ingestion/ometa/mixins/server_mixin.py

@@ -49,6 +49,24 @@ class OMetaServerMixin:
 
     client: REST
 
+    @property
+    def server_version(self) -> str:
+        """
+        Server version property
+        """
+        if not hasattr(self, "_server_version") or self._server_version is None:
+            self._server_version = self.get_server_version()
+        return self._server_version
+
+    @property
+    def client_version(self) -> str:
+        """
+        Client version property
+        """
+        if not hasattr(self, "_client_version") or self._client_version is None:
+            self._client_version = get_client_version()
+        return self._client_version
+
     def get_server_version(self) -> str:
         """
         Run endpoint /system/version to check server version
@@ -68,16 +86,13 @@ def validate_versions(self) -> None:
         Validate Server & Client versions. They should match.
         Otherwise, raise VersionMismatchException
         """
-        server_version = self.get_server_version()
-        client_version = get_client_version()
-
         logger.info(
-            f"OpenMetadata client running with Server version [{server_version}] and Client version [{client_version}]"
+            f"OpenMetadata client running with Server version [{self.server_version}] and Client version [{self.client_version}]"
         )
 
-        if not match_versions(server_version, client_version):
+        if not match_versions(self.server_version, self.client_version):
             raise VersionMismatchException(
-                f"Server version is {server_version} vs. Client version {client_version}."
+                f"Server version is {self.server_version} vs. Client version {self.client_version}."
                 f" Major and minor versions should match."
             )
 

ingestion/src/metadata/utils/streamable_logger.py

@@ -553,6 +553,7 @@ def setup_streamable_logging_for_workflow(
         logger.info(
             f"Streamable logging configured for pipeline: {pipeline_fqn}, run_id: {model_str(run_id)}"
         )
+        metadata.validate_versions()  # Send the version check log
 
         return handler