Merge branch 'master' of http://gogsb.soaringnova.com/sxwl_DL/datax-admin

Dockerfile

@@ -68,7 +68,7 @@ RUN mamba update -n base -c defaults conda -y && mamba env create -f /environmen
 RUN echo "\
 [program:be]\n\
 directory=%(ENV_WORKDIR)s\n\
-command= /opt/conda/envs/py38/bin/gunicorn  server:app -b 0.0.0.0:8080 --reload  -k utils.r_uvicorn_worker.RestartableUvicornWorker \n\
+command= /opt/conda/envs/py38/bin/gunicorn  server:app -b 0.0.0.0:8080 --reload  -k utils.r_uvicorn_worker.RestartableUvicornWorker -w 2 \n\
 autorestart=true\n\
 startretries=1000\n\
 redirect_stderr=true\n\

app/services/dag.py

@@ -125,7 +125,8 @@ def get_tmp_table_name(dag_uuid: str, node_id: str, out_pin: str, db: Session):
     if task_id:
         table_name = f'job{job_id}_task{task_id}_subnode{node_id}_output{out_pin}_tmp'
         t_list = hiveDs.list_tables()
-        if table_name.lower() not in t_list:
+        table_name = table_name.lower()
+        if table_name not in t_list:
             raise Exception('该节点不存在中间结果')
         return table_name
     else:

server.py

@@ -57,7 +57,7 @@ print('server init finish:)!!!')
 
 
 # Get 健康检查
-@app.get("/ping", description="健康检查")
+@app.get("/jpt/ping", description="健康检查")
 def ping():
     return "pong!!"