Set taskEventStore column in the new engine

Author: matt-aitken

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

@@ -31,6 +31,7 @@ import {
   TriggerTaskServiceResult,
 } from "./triggerTask.server";
 import { WorkerGroupService } from "./worker/workerGroupService.server";
+import { getTaskEventStore } from "../taskEventStore.server";
 
 /** @deprecated Use TriggerTaskService in `triggerTask.server.ts` instead. */
 export class TriggerTaskServiceV2 extends WithRunEngine {
@@ -355,6 +356,7 @@ export class TriggerTaskServiceV2 extends WithRunEngine {
                     delayUntil,
                     queuedAt: delayUntil ? undefined : new Date(),
                     maxAttempts: body.options?.maxAttempts,
+                    taskEventStore: getTaskEventStore(),
                     ttl,
                     tags,
                     oneTimeUseToken: options.oneTimeUseToken,

internal-packages/run-engine/src/engine/index.ts

@@ -246,6 +246,7 @@ export class RunEngine {
       delayUntil,
       queuedAt,
       maxAttempts,
+      taskEventStore,
       priorityMs,
       ttl,
       tags,
@@ -329,6 +330,7 @@ export class RunEngine {
               delayUntil,
               queuedAt,
               maxAttempts,
+              taskEventStore,
               priorityMs,
               ttl,
               tags:

internal-packages/run-engine/src/engine/types.ts

@@ -65,6 +65,7 @@ export type TriggerParams = {
   delayUntil?: Date;
   queuedAt?: Date;
   maxAttempts?: number;
+  taskEventStore: string;
   priorityMs?: number;
   ttl?: string;
   tags: { id: string; name: string }[];