Function upsertActivity

packages/infra/src/WorkflowEngineSqlite.ts:364–376

(
    executionId: string,
    name: string,
    attempt: number,
    encoded: string
  )

  // Overwrites a previously persisted *suspended* activity result so the next
  // attempt can record its real outcome.
  const upsertActivity = (
    executionId: string,
    name: string,
    attempt: number,
    encoded: string
  ): Effect.Effect<void> =>
    exec(
      `INSERT INTO "${activityTable}" (execution_id, name, attempt, result)
       VALUES (?, ?, ?, ?)
       ON CONFLICT(execution_id, name, attempt) DO UPDATE SET result = excluded.result`,
      [executionId, name, attempt, encoded]
    )
      .pipe(Effect.asVoid)

  const readActivity = (
    executionId: string,