moved some run logic into children

digitalhub/entities/run/_base/entity.py

@@ -86,16 +86,15 @@ def run(self) -> Run:
             self._set_state(State.RUNNING.value)
             self.save(update=True)
 
-        # Try to get inputs if they exist
-        try:
-            self.spec.inputs = self.inputs(as_dict=True)
-        except EntityError:
-            pass
+        self._setup_execution()
 
         try:
             status = self._get_runtime().run(self.to_dict())
         except Exception as e:
             self.refresh()
+            import pdb
+
+            pdb.set_trace()
             if self.spec.local_execution:
                 self._set_state(State.ERROR.value)
             self._set_message(str(e))
@@ -194,6 +193,15 @@ def resume(self) -> None:
     #  Helpers
     ##############################
 
+    def _setup_execution(self) -> None:
+        """
+        Setup run execution. In base class, nothing to do.
+
+        Returns
+        -------
+        None
+        """
+
     def _is_ready_to_run(self) -> bool:
         """
         Check if run is in a state ready for running (BUILT or STOPPED).

pyproject.toml

@@ -4,7 +4,7 @@ build-backend = "setuptools.build_meta"
 
 [project]
 name = "digitalhub"
-version = "0.8.0b4"
+version = "0.8.0b5"
 description = "Python SDK for Digitalhub"
 readme = "README.md"
 authors = [
@@ -77,7 +77,7 @@ line-length = 120
 convention = "numpy"
 
 [tool.bumpver]
-current_version = "0.8.0b4"
+current_version = "0.8.0b5"
 version_pattern = "MAJOR.MINOR.PATCH[PYTAGNUM]"
 commit_message  = "Bump version {old_version} -> {new_version}"
 commit          = false

runtimes/container/pyproject.toml

@@ -4,7 +4,7 @@ build-backend = "setuptools.build_meta"
 
 [project]
 name = "digitalhub-runtime-container"
-version = "0.8.0b4"
+version = "0.8.0b5"
 description = "Container runtime for DHCore"
 readme = "README.md"
 authors = [
@@ -40,7 +40,7 @@ line-length = 120
 convention = "numpy"
 
 [tool.bumpver]
-current_version = "0.8.0b4"
+current_version = "0.8.0b5"
 version_pattern = "MAJOR.MINOR.PATCH[PYTAGNUM]"
 commit_message  = "Bump version {old_version} -> {new_version}"
 commit          = false

runtimes/dbt/digitalhub_runtime_dbt/entities/run/dbt_run/entity.py

@@ -32,6 +32,17 @@ def __init__(
         self.spec: RunSpecDbtRun
         self.status: RunStatusDbtRun
 
+    def _setup_execution(self) -> None:
+        """
+        Setup run execution.
+
+        Returns
+        -------
+        None
+        """
+        self.refresh()
+        self.spec.inputs = self.inputs(as_dict=True)
+
     def inputs(self, as_dict: bool = False) -> list[dict]:
         """
         Get inputs passed in spec as objects or as dictionaries.

runtimes/dbt/pyproject.toml

@@ -4,7 +4,7 @@ build-backend = "setuptools.build_meta"
 
 [project]
 name = "digitalhub-runtime-dbt"
-version = "0.8.0b4"
+version = "0.8.0b5"
 description = "Dbt runtime for DHCore"
 readme = "README.md"
 authors = [
@@ -45,7 +45,7 @@ line-length = 120
 convention = "numpy"
 
 [tool.bumpver]
-current_version = "0.8.0b4"
+current_version = "0.8.0b5"
 version_pattern = "MAJOR.MINOR.PATCH[PYTAGNUM]"
 commit_message  = "Bump version {old_version} -> {new_version}"
 commit          = false

runtimes/kfp/digitalhub_runtime_kfp/entities/run/kfp_run/entity.py

@@ -35,6 +35,17 @@ def __init__(
         self.spec: RunSpecKfpRun
         self.status: RunStatusKfpRun
 
+    def _setup_execution(self) -> None:
+        """
+        Setup run execution.
+
+        Returns
+        -------
+        None
+        """
+        self.refresh()
+        self.spec.inputs = self.inputs(as_dict=True)
+
     def inputs(self, as_dict: bool = False) -> list[dict]:
         """
         Get inputs passed in spec as objects or as dictionaries.

runtimes/kfp/pyproject.toml

@@ -4,7 +4,7 @@ build-backend = "setuptools.build_meta"
 
 [project]
 name = "digitalhub-runtime-kfp"
-version = "0.8.0b4"
+version = "0.8.0b5"
 description = "KFP runtime for DHCore"
 readme = "README.md"
 authors = [
@@ -44,7 +44,7 @@ line-length = 120
 convention = "numpy"
 
 [tool.bumpver]
-current_version = "0.8.0b4"
+current_version = "0.8.0b5"
 version_pattern = "MAJOR.MINOR.PATCH[PYTAGNUM]"
 commit_message  = "Bump version {old_version} -> {new_version}"
 commit          = false

runtimes/modelserve/pyproject.toml

@@ -4,7 +4,7 @@ build-backend = "setuptools.build_meta"
 
 [project]
 name = "digitalhub-runtime-modelserve"
-version = "0.8.0b4"
+version = "0.8.0b5"
 description = "ML Model serving runtime for DHCore"
 readme = "README.md"
 authors = [
@@ -51,7 +51,7 @@ line-length = 120
 convention = "numpy"
 
 [tool.bumpver]
-current_version = "0.8.0b4"
+current_version = "0.8.0b5"
 version_pattern = "MAJOR.MINOR.PATCH[PYTAGNUM]"
 commit_message  = "Bump version {old_version} -> {new_version}"
 commit          = false

runtimes/python/digitalhub_runtime_python/entities/run/python_run/entity.py

@@ -35,6 +35,17 @@ def __init__(
         self.spec: RunSpecPythonRun
         self.status: RunStatusPythonRun
 
+    def _setup_execution(self) -> None:
+        """
+        Setup run execution.
+
+        Returns
+        -------
+        None
+        """
+        self.refresh()
+        self.spec.inputs = self.inputs(as_dict=True)
+
     def inputs(self, as_dict: bool = False) -> list[dict]:
         """
         Get inputs passed in spec as objects or as dictionaries.

runtimes/python/pyproject.toml

@@ -4,7 +4,7 @@ build-backend = "setuptools.build_meta"
 
 [project]
 name = "digitalhub-runtime-python"
-version = "0.8.0b4"
+version = "0.8.0b5"
 description = "Python runtime for DHCore"
 readme = "README.md"
 authors = [
@@ -40,7 +40,7 @@ line-length = 120
 convention = "numpy"
 
 [tool.bumpver]
-current_version = "0.8.0b4"
+current_version = "0.8.0b5"
 version_pattern = "MAJOR.MINOR.PATCH[PYTAGNUM]"
 commit_message  = "Bump version {old_version} -> {new_version}"
 commit          = false