1 files changed, 0 insertions, 42 deletions
diff --git a/worker/executor/job.ts b/worker/executor/job.ts
deleted file mode 100644
index ca7feed..0000000
--- a/worker/executor/job.ts
+++ /dev/null
@@ -1,42 +0,0 @@
-import {
-  getStdout,
-  type ITraceable,
-  LogLevel,
-  type LogMetricTraceSupplier,
-  memoize,
-  Metric,
-  TraceUtil,
-  validateExecutionEntries,
-} from "@emprespresso/pengueno";
-import type { Job } from "@emprespresso/ci-model";
-
-const jobTypeMetric = memoize((type: string) => Metric.fromName(`run.${type}`));
-export const executeJob = (tJob: ITraceable<Job, LogMetricTraceSupplier>) =>
-  tJob
-    .bimap(TraceUtil.withMetricTrace(jobTypeMetric(tJob.get().type)))
-    .peek((tJob) =>
-      tJob.trace.trace(`let's do this little job ok!! ${tJob.get()}`),
-    )
-    .map((tJob) =>
-      validateExecutionEntries(tJob.get().arguments)
-        .mapLeft((badEntries) => {
-          tJob.trace.addTrace(LogLevel.ERROR).trace(badEntries.toString());
-          return new Error("invalid job arguments");
-        })
-        .flatMapAsync((args) =>
-          getStdout(tJob.move(tJob.get().type), { env: args }),
-        ),
-    )
-    .peek(
-      TraceUtil.promiseify((q) =>
-        q.trace.trace(
-          q
-            .get()
-            .fold(
-              (err, _val) =>
-                jobTypeMetric(tJob.get().type)[err ? "failure" : "success"],
-            ),
-        ),
-      ),
-    )
-    .get();