diff --git a/bin/worker.py b/bin/worker.py index 60b0c76..e870863 100755 --- a/bin/worker.py +++ b/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}") diff --git a/bin/worker_transfert.sh b/bin/worker_transfert.sh new file mode 100755 index 0000000..09c6edd --- /dev/null +++ b/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 + diff --git a/dockers/paheko/docker-compose.yml.dist b/dockers/paheko/docker-compose.yml.dist index 1dacbab..214710c 100644 --- a/dockers/paheko/docker-compose.yml.dist +++ b/dockers/paheko/docker-compose.yml.dist @@ -11,6 +11,7 @@ services: - assoUsers:/var/www/paheko/users - /etc/localtime:/etc/localtime:ro - /etc/timezone:/etc/timezone:ro + - /kaz/jobs:/var/www/paheko/jobs # ports: # - 8086:80 networks: