envoi d'un msg MM en cas d'ano sur le job

pouvoir trasferer les jobs sur des srv tiers

bin/worker.py

@@ -297,6 +297,13 @@ except Exception as e:
         f"Erreur lors du traitement du job : {e}"
     )
 
+    message_mattermost = (
+        "**Erreur lors du traitement d'un job KAZ**\n\n"
+        f"Job : `{job}`\n"
+        f"Erreur : `{e}`\n"
+    )
+    send_mattermost(message_mattermost)
+
     try:
         os.rename(encours, ko)
         log.info(f"Job marqué KO : {ko}")

bin/worker_transfert.sh

@@ -0,0 +1,32 @@
+#!/bin/bash
+
+#KAN: 30/09/2026
+#KOI: transférer les jobs vers les serveurs secondaires
+#KI: fab
+
+JOBS_DIR="/kaz/tmp/jobs"
+
+for job in "$JOBS_DIR"/*.json; do
+
+    [ -e "$job" ] || continue
+
+    destination=$(jq -r '.destination // empty' "$job")
+
+    if [ -z "$destination" ]; then
+        echo "Destination absente dans $job"
+        continue
+    fi
+
+    destination="${destination}.kaz.bzh"
+
+    echo "Transfert de $job vers $destination:/kaz/jobs/"
+
+    if rsync -a -e 'ssh -p 2201' "$job" "$destination:/kaz/jobs/"; then
+        echo "Transfert OK : $job"
+        mv "$job" "$job.transfere"
+    else
+        echo "Échec du transfert : $job"
+    fi
+
+done
+