diff --git a/L1/dockerfiles/csst-msc-l1-mbi-photmix/run.sh b/L1/dockerfiles/csst-msc-l1-mbi-photmix/run.sh
index 8ab205a5875777cae88f4d20e6c9a37caf014348..893463d3d09bd5c80a07d7d9a495a30456a28c06 100644
--- a/L1/dockerfiles/csst-msc-l1-mbi-photmix/run.sh
+++ b/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
diff --git a/L1/dockerfiles/csst-msc-l1-mbi/run.sh b/L1/dockerfiles/csst-msc-l1-mbi/run.sh
index d16def22663392bf2312954c59a7ea8eb2ee46ab..11bc82ce10fd6625c7e8a9573161c33909372d1c 100644
--- a/L1/dockerfiles/csst-msc-l1-mbi/run.sh
+++ b/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"  
diff --git a/L1/dockerfiles/csst-msc-l1-qc0/run.sh b/L1/dockerfiles/csst-msc-l1-qc0/run.sh
index b94a75c92b8a5521745080d9229e9429ae38e867..d5cdeee7af2a7ed4529c525df66148b5675d07bf 100644
--- a/L1/dockerfiles/csst-msc-l1-qc0/run.sh
+++ b/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"