From b69743528ce614f3680b629690c20ebdb6944b7b Mon Sep 17 00:00:00 2001
From: tianweidut <liutianweidlut@gmail.com>
Date: Fri, 23 Sep 2022 11:13:09 +0800
Subject: [PATCH] refactor sw-docker-entrypiont with split swmp and swrt
 workdir

---
 client/scripts/sw-docker-entrypoint    | 33 ++++++++++++++++++--------
 client/starwhale/base/type.py          |  1 +
 client/starwhale/core/eval/executor.py |  2 +-
 3 files changed, 25 insertions(+), 11 deletions(-)

diff --git a/client/scripts/sw-docker-entrypoint b/client/scripts/sw-docker-entrypoint
index 80b4561cbc..935fbe1dae 100755
--- a/client/scripts/sw-docker-entrypoint
+++ b/client/scripts/sw-docker-entrypoint
@@ -9,9 +9,9 @@ fi
 ulimit -n 65535 || true
 
 CONDA_BIN="/opt/miniconda3/bin"
-WORKDIR=${SW_SWMP_WORKDIR:=/opt/starwhale/swmp}
+SWMP_DIR=${SW_SWMP_WORKDIR:=/opt/starwhale/swmp}
+SWRT_DIR=${SW_SWRT_WORKDIR:=/opt/starwhale/swrt}
 PIP_CACHE_DIR=${SW_PIP_CACHE_DIR:=/root/.cache/pip}
-_MANIFEST_RUNTIME=$(yq -r .environment.python ${WORKDIR}/_manifest.yaml) || true
 VERBOSE="-vvvv"
 STEP=${SW_TASK_STEP:-""}
 TASK_INDEX=${SW_TASK_INDEX:-0}
@@ -59,15 +59,25 @@ set_pip_cache() {
 
 pre_check() {
     echo "--> run pre check for swmp model dir ..."
-    cd ${WORKDIR}
+    if [ ! -f "${SWMP_DIR}/model.yaml" ] || [ ! -d "${SWMP_DIR}/src" ]; then
+        echo "${SWMP_DIR} is not starwhale swmp target dir, will exit"
+        exit 1
+    fi
+
+    echo "--> run pre check for swrt runtime dir ..."
+    if [ ! -f "${SWRT_DIR}/_manifest.yaml" ] || [ ! -d "${SWRT_DIR}/dependencies" ]; then
+        echo "${SWRT_DIR} is not starwhale swrt target dir, will exit"
+        exit 1
+    fi
 
-    if [ ! -f "_manifest.yaml" ] || [ ! -f "model.yaml" ]; then
-        echo "${WORKDIR} is not starwhale target dir, will exit"
+    if [ "${SWRT_DIR}" = "${SWMP_DIR}" ]; then
+        echo "swmp and swrt use the same dir, will exit"
         exit 1
     fi
 }
 
 set_python() {
+    _MANIFEST_RUNTIME=$(yq -r .environment.python ${SWRT_DIR}/_manifest.yaml) || exit 1
     _RUNTIME="python${_MANIFEST_RUNTIME}"
 
     echo "**** DETECT RUNTIME: ${_RUNTIME}"
@@ -78,20 +88,21 @@ set_python() {
         _update_python_alter "python3.8"
     fi
 }
+
 # TODO:restore when processing evaluation(eval run use param: 'runtime URI', and it can be uri or dir path )
 restore_activate_runtime() {
     echo '--> restore python env ...'
     export PYTHONWARNINGS="ignore:Unverified HTTPS request"
-    swcli ${VERBOSE} runtime restore .
+    swcli ${VERBOSE} runtime restore ${SWRT_DIR} || exit 1
     unset PYTHONWARNINGS
 
     echo '--> source activate ...'
-    eval "$(./activate.sw)"
+    eval "$(${SWRT_DIR}/activate.sw)" || exit 1
 }
 
 run() {
-    echo "--> start to run swmp ${STEP}, use $(which swcli) cli..."
-    swcli ${VERBOSE} model eval "${WORKDIR}"/src --dataset=${SW_DATASET_URI} --step=${STEP} --task-index=${TASK_INDEX} --version=${SW_EVALUATION_VERSION}
+    echo "--> start to run swmp ${STEP}, use $(which swcli) cli @ ${SWMP_DIR} ..."
+    swcli ${VERBOSE} model eval "${SWMP_DIR}"/src --dataset=${SW_DATASET_URI} --step=${STEP} --task-index=${TASK_INDEX} --version=${SW_EVALUATION_VERSION} || exit 1
 }
 
 welcome() {
@@ -100,7 +111,9 @@ welcome() {
     echo "Date: `date -u +%Y-%m-%dT%H:%M:%SZ`"
     echo "Version: `swcli --version`"
     echo "Run: $1 "
-    echo "Model: ${SW_SWMP_NAME}@${SW_SWMP_VERSION}"
+    echo "Model Version: ${SW_SWMP_NAME}@${SW_SWMP_VERSION}"
+    echo "Model Workdir: ${SWMP_DIR}"
+    echo "Runtime Workdir: ${SWRT_DIR}"
     echo "===================================="
 }
 
diff --git a/client/starwhale/base/type.py b/client/starwhale/base/type.py
index 8138388f4c..3f26c87687 100644
--- a/client/starwhale/base/type.py
+++ b/client/starwhale/base/type.py
@@ -33,6 +33,7 @@ class RunSubDirType:
     RUNLOG = "runlog"
     LOG = "log"
     SWMP = "swmp"
+    SWRT = "swrt"
 
 
 class JobOperationType:
diff --git a/client/starwhale/core/eval/executor.py b/client/starwhale/core/eval/executor.py
index e82704617e..ee4a5b8a38 100644
--- a/client/starwhale/core/eval/executor.py
+++ b/client/starwhale/core/eval/executor.py
@@ -216,7 +216,7 @@ def _gen_run_container_cmd(self, typ: str, step: str, task_index: int) -> str:
             "-v",
             f"{self._model_dir}/{DefaultYAMLName.MODEL}:{_CNTR_WORKDIR}/{RunSubDirType.SWMP}/{DefaultYAMLName.MODEL}",
             "-v",
-            f"{self._runtime_dir}:{_CNTR_WORKDIR}/{RunSubDirType.SWMP}",
+            f"{self._runtime_dir}:{_CNTR_WORKDIR}/{RunSubDirType.SWRT}",
         ]
 
         if typ == EvalTaskType.SINGLE: