增加 --header repeatable=yes 可修改正在运行的task状态，使其重新执行

L1/dockerfiles/csst-msc-l1-mbi-photmix/run.sh

@@ -22,8 +22,24 @@ if test -f "$timefile"; then
     mv /pipeline/output/timestamp.txt /work/timestamps.txt
 fi
 
-rm -rf /pipeline/input/* /pipeline/output/*
+headers=$2
+pattern='"dag_run_id":"([^"]+)"'
+if [[ $headers =~ $pattern ]]; then
+    dag_run_id="${BASH_REMATCH[1]}"
+    echo "dag_run_id: $dag_run_id"
+else
+    # no dag_run_id in json
+    dag_run_id=""
+fi
 
-echo finish photmix.
+echo "dag_run_id:$dag_run_id" >> /work/extra-attributes.txt
+if [ $exit_code -eq 0 ]; then  
+  echo finish photmix.
+  # scalebox task add $1
+else  
+  echo "finish photmix, exit_code: $exit_code"  
+fi
+
+rm -rf /pipeline/input/* /pipeline/output/*
 
 exit $exit_code

L1/dockerfiles/csst-msc-l1-mbi/run.sh

@@ -33,9 +33,11 @@ else
     dag_run_id=""
 fi
 
+echo "dag_run_id:$dag_run_id" >> /work/extra-attributes.txt
+
 if [ $exit_code -eq 0 ]; then  
   echo "finish mbi, start sink-job."  
-  scalebox task add --header dag_run_id=${dag_run_id} --upsert ${message}
+  scalebox task add --header dag_run_id=${dag_run_id} --header repeatable=yes --upsert ${message}
   # scalebox task add $1
 else  
   echo "finish mbi, exit_code: $exit_code"  

L1/dockerfiles/csst-msc-l1-qc0/run.sh

@@ -34,9 +34,10 @@ else
     dag_run_id=""
 fi
 
-if [ $exit_code -eq 0 ]; then  
-    scalebox task add --header dag_run_id=${dag_run_id} --upsert ${message}
+echo "dag_run_id:$dag_run_id" >> /work/extra-attributes.txt
 
+if [ $exit_code -eq 0 ]; then  
+    scalebox task add --header dag_run_id=${dag_run_id} --header repeatable=yes --upsert ${message}
     echo "finish qc0, start sink-job."  
 else  
     echo "finish qc0, exit_code: $exit_code"