Improve checkpoint reliability and cleanup of temp files

apps/coordinator/package.json

@@ -17,10 +17,10 @@
   "license": "MIT",
   "dependencies": {
     "@trigger.dev/core": "workspace:*",
-    "execa": "^8.0.1",
     "nanoid": "^5.0.6",
     "prom-client": "^15.1.0",
-    "socket.io": "4.7.4"
+    "socket.io": "4.7.4",
+    "tinyexec": "^0.3.0"
   },
   "devDependencies": {
     "@types/node": "^18",

apps/coordinator/src/chaosMonkey.ts

@@ -1,4 +1,3 @@
-import type { Execa$ } from "execa";
 import { setTimeout as timeout } from "node:timers/promises";
 
 class ChaosMonkeyError extends Error {
@@ -35,11 +34,9 @@ export class ChaosMonkey {
   }
 
   async call({
-    $,
     throwErrors = !this.disableErrors,
     addDelays = !this.disableDelays,
   }: {
-    $?: Execa$<string>;
     throwErrors?: boolean;
     addDelays?: boolean;
   } = {}) {
@@ -60,23 +57,15 @@ export class ChaosMonkey {
       chaosEvents.push(async () => {
         console.log("🍌 Chaos monkey: Add delay");
 
-        if ($) {
-          await $`sleep ${this.delayInSeconds}`;
-        } else {
-          await timeout(this.delayInSeconds * 1000);
-        }
+        await timeout(this.delayInSeconds * 1000);
       });
     }
 
     if (throwErrors) {
       chaosEvents.push(async () => {
         console.log("🍌 Chaos monkey: Throw error");
 
-        if ($) {
-          await $`false`;
-        } else {
-          throw new ChaosMonkey.Error("🍌 Chaos monkey: Throw error");
-        }
+        throw new ChaosMonkey.Error("🍌 Chaos monkey: Throw error");
       });
     }