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
@@ -26,8 +26,12 @@ def _connected(self):
     @property
     def pipeline_run_id(self) -> Any:
         """Get the current pipeline run ID."""
-        if self._connected:
-            return get_openhexa().current_pipeline_run()["id"]
+        self._is_connected()
+        return OpenHexaClient().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. "
@@ -36,13 +40,8 @@ def pipeline_run_id(self) -> Any:
 
     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.