Update run_all.py

Author: juanmoisesd

scripts/run_all.py

@@ -3,8 +3,8 @@
 
 import subprocess
 import sys
+from datetime import datetime, timezone
 from pathlib import Path
-from datetime import datetime
 
 # Orden de ejecución del pipeline
 SCRIPTS = [
@@ -16,6 +16,10 @@
 ]
 
 
+def now_utc() -> str:
+    return datetime.now(timezone.utc).isoformat(timespec="seconds")
+
+
 def run_script(script: Path, root: Path) -> int:
     print(f"\n>>> Ejecutando {script.name}")
     result = subprocess.run(
@@ -29,44 +33,46 @@ def run_script(script: Path, root: Path) -> int:
 def main() -> int:
     base = Path(__file__).resolve().parent
     root = base.parent
+    started_at = datetime.now(timezone.utc)
 
     print("===================================")
     print("Demographic Dataset Pipeline")
-    print("Inicio:", datetime.utcnow().isoformat(), "UTC")
+    print("Inicio:", now_utc(), "UTC")
     print("Python:", sys.version.split()[0])
+    print("Raíz del proyecto:", root)
     print("===================================\n")
 
-    failures = []
-
     for name in SCRIPTS:
         script = base / name
 
         if not script.exists():
             print(f"ERROR: no se encontró el script {script}", file=sys.stderr)
-            failures.append(name)
-            continue
+            return 1
 
         code = run_script(script, root)
 
         if code != 0:
-            print(f"ERROR: fallo en {script.name} con código {code}", file=sys.stderr)
-            failures.append(name)
+            print("\n===================================")
+            print(f"Pipeline interrumpido por error en {script.name}.", file=sys.stderr)
+            print(f"Código de salida: {code}", file=sys.stderr)
+            print("Fin:", now_utc(), "UTC", file=sys.stderr)
+            print("===================================")
+            return code
 
-    print("\n===================================")
-
-    if failures:
-        print("Pipeline finalizado con errores.")
-        print("Scripts con fallo:")
-        for f in failures:
-            print(f" - {f}")
-        return 1
+    finished_at = datetime.now(timezone.utc)
+    duration = finished_at - started_at
 
+    print("\n===================================")
     print("Pipeline completado correctamente.")
-    print("Fin:", datetime.utcnow().isoformat(), "UTC")
+    print("Fin:", now_utc(), "UTC")
+    print("Duración total:", duration)
     print("===================================")
-
     return 0
 
 
 if __name__ == "__main__":
-    raise SystemExit(main())
+    try:
+        raise SystemExit(main())
+    except KeyboardInterrupt:
+        print("\nERROR: ejecución interrumpida por el usuario.", file=sys.stderr)
+        raise SystemExit(130)