Skip to content

Commit 5f9dd3a

Browse files
committed
feature: 支持启动时安装算子包
1 parent 7e3039b commit 5f9dd3a

File tree

1 file changed

+4
-5
lines changed

1 file changed

+4
-5
lines changed

tools/utils/load_operators.sh

Lines changed: 4 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -58,7 +58,6 @@ fi
5858

5959
BACKEND_POD_NAME=$(kubectl get pod -n "$NAMESPACE" -l app.kubernetes.io/name=datamate-backend -o jsonpath='{.items[*].metadata.name}')
6060
HEAD_POD_NAME=$(kubectl get pod -n "$NAMESPACE" -l app.kubernetes.io/name=kuberay,ray.io/node-type=head -o jsonpath='{.items[*].metadata.name}')
61-
VALUES=""
6261

6362
# 3. 遍历并处理子压缩包
6463
# 查找目录下所有的 zip 或 tar.gz
@@ -96,11 +95,11 @@ while read -r pkg; do
9695

9796
log_info " -> 部署文件到容器 $BACKEND_POD_NAME:$REMOTE_PATH"
9897

99-
# kubectl cp "$SOURCE_DIR/$PKG_NAME" "$BACKEND_POD_NAME:$UPLOAD_DIR/"
100-
kubectl cp "$PKG_EXTRACT_DIR" "$BACKEND_POD_NAME:$REMOTE_PATH/"
98+
# kubectl cp "$SOURCE_DIR/$PKG_NAME" "$BACKEND_POD_NAME:$UPLOAD_DIR/" -n "$NAMESPACE"
99+
kubectl cp "$PKG_EXTRACT_DIR" "$BACKEND_POD_NAME:$REMOTE_PATH/" -n "$NAMESPACE"
101100

102101
if [ -f "$PKG_EXTRACT_DIR/wheels" ]; then
103-
kubectl exec "$HEAD_POD_NAME" -- bash -c "uv pip install --target $PACKAGE_DIR /opt/runtime/datamate/ops/user/$PKG_BASE/wheels/*.whl"
102+
kubectl exec "$HEAD_POD_NAME" -n "$NAMESPACE" -- bash -c "uv pip install --target $PACKAGE_DIR /opt/runtime/datamate/ops/user/$PKG_BASE/wheels/*.whl"
104103
fi
105104
done < <(find "$SOURCE_DIR" -maxdepth 1 -type f \( -name "*.zip" -o -name "*.tar" \))
106105

@@ -151,6 +150,6 @@ EOF
151150
)
152151

153152
DATABASE_POD_NAME=$(kubectl get pod -n "$NAMESPACE" -l app.kubernetes.io/name=datamate-database -o jsonpath='{.items[*].metadata.name}')
154-
kubectl exec -i "$DATABASE_POD_NAME" -- mysql -uroot -p"\$MYSQL_ROOT_PASSWORD" "datamate" -e "$FULL_SQL" 2>/dev/null
153+
kubectl exec -i "$DATABASE_POD_NAME" -n "$NAMESPACE" -- mysql -uroot -p"\$MYSQL_ROOT_PASSWORD" "datamate" -e "$FULL_SQL" 2>/dev/null
155154

156155
log_info "所有任务执行完毕。"

0 commit comments

Comments
 (0)