fix: fixes pieplines

Author: nazarfil

openhexa/sdk/pipelines/run.py

@@ -6,7 +6,7 @@
 from typing import Any
 
 from openhexa.graphql import CurrentPipelineRunCurrentPipelineRunPipeline
-from openhexa.sdk.client import get_openhexa
+from openhexa.sdk.client import OpenHexaClient
 from openhexa.sdk.pipelines.log_level import LogLevel
 from openhexa.sdk.utils import Environment, get_environment, graphql
 from openhexa.sdk.workspaces import workspace
@@ -23,26 +23,25 @@ class CurrentRun:
     def _connected(self):
         return "HEXA_SERVER_URL" in os.environ
 
-    @property
-    def pipeline_run_id(self) -> Any:
-        """Get the current pipeline run ID."""
-        if self._connected:
-            return get_openhexa().current_pipeline_run()["id"]
+    def _is_connected(self):
+        if "HEXA_SERVER_URL" in os.environ:
+            return True
         else:
             raise RuntimeError(
                 "CurrentRun is not connected to the OpenHEXA server. "
                 "Make sure to set the HEXA_SERVER_URL environment variable."
             )
 
+    @property
+    def pipeline_run_id(self) -> Any:
+        """Get the current pipeline run ID."""
+        self._is_connected()
+        return OpenHexaClient().current_pipeline_run().id
+
     def get_pipline(self) -> CurrentPipelineRunCurrentPipelineRunPipeline:
         """Get the current pipeline."""
-        if self._connected:
-            return get_openhexa().current_pipeline_run()["pipeline"]
-        else:
-            raise RuntimeError(
-                "CurrentRun is not connected to the OpenHEXA server. "
-                "Make sure to set the HEXA_SERVER_URL environment variable."
-            )
+        self._is_connected()
+        return OpenHexaClient().current_pipeline_run().pipeline
 
     def add_file_output(self, path: str):
         """Record a run output for a file creation operation.