A couple of improvements

Author: ericallam

apps/webapp/app/utils/requestIdempotency.server.ts

@@ -1,4 +1,5 @@
 import { json } from "@remix-run/server-runtime";
+import { tryCatch } from "@trigger.dev/core/utils";
 import { logger } from "~/services/logger.server";
 import { requestIdempotency } from "~/services/requestIdempotencyInstance.server";
 import { startActiveSpan } from "~/v3/tracer.server";
@@ -78,7 +79,18 @@ export async function saveRequestIdempotency(
     return;
   }
 
-  await requestIdempotency.saveRequest(requestType, requestIdempotencyKey, {
-    id: entityId,
-  });
+  const [error] = await tryCatch(
+    requestIdempotency.saveRequest(requestType, requestIdempotencyKey, {
+      id: entityId,
+    })
+  );
+
+  if (error) {
+    logger.error("request-idempotency: error saving request", {
+      error,
+      requestIdempotencyKey,
+      requestType,
+      entityId,
+    });
+  }
 }

apps/webapp/app/v3/services/triggerTask.server.ts

@@ -1,9 +1,12 @@
 import { TriggerTaskRequestBody } from "@trigger.dev/core/v3";
 import { RunEngineVersion, TaskRun } from "@trigger.dev/database";
+import { env } from "~/env.server";
 import { IdempotencyKeyConcern } from "~/runEngine/concerns/idempotencyKeys.server";
 import { DefaultPayloadProcessor } from "~/runEngine/concerns/payloads.server";
 import { DefaultQueueManager } from "~/runEngine/concerns/queues.server";
+import { DefaultRunChainStateManager } from "~/runEngine/concerns/runChainStates.server";
 import { DefaultRunNumberIncrementer } from "~/runEngine/concerns/runNumbers.server";
+import { DefaultTraceEventsConcern } from "~/runEngine/concerns/traceEvents.server";
 import { RunEngineTriggerTaskService } from "~/runEngine/services/triggerTask.server";
 import { DefaultTriggerTaskValidator } from "~/runEngine/validators/triggerTaskValidator";
 import { AuthenticatedEnvironment } from "~/services/apiAuth.server";
@@ -12,10 +15,6 @@ import { eventRepository } from "../eventRepository.server";
 import { tracer } from "../tracer.server";
 import { WithRunEngine } from "./baseService.server";
 import { TriggerTaskServiceV1 } from "./triggerTaskV1.server";
-import { DefaultTraceEventsConcern } from "~/runEngine/concerns/traceEvents.server";
-import { DefaultRunChainStateManager } from "~/runEngine/concerns/runChainStates.server";
-import { env } from "~/env.server";
-import { Evt } from "evt";
 
 export type TriggerTaskServiceOptions = {
   idempotencyKey?: string;