AI Worker form Workflow throws Network connection lost Name: AiError

import {
    WorkflowEntrypoint,
    type WorkflowEvent,
    type WorkflowStep,
} from "cloudflare:workers";
import { NonRetryableError } from "cloudflare:workflows";
import type { FlipperBinding } from "@repo/types";

export type WorkflowVideoParams = {
    key: string;
};

export class WorkflowVideo extends WorkflowEntrypoint<
    FlipperBinding,
    WorkflowVideoParams
> {
    async run(event: WorkflowEvent<WorkflowVideoParams>, step: WorkflowStep) {
        // Can access bindings on `this.env`
        // Can access params on `event.payload`
        let video: R2ObjectBody | null;
        await step.do("getting video from R2", async () => {
            console.log("getting video from R2");
            video = await this.env.COVE_STORAGE.get(event.payload.key);
            if (!video) {
                throw new Error("Video not found in storage.");
            }
        });

        await step.do("ai video", async () => {
            if (!video) {
                throw new Error(
                    "Not processing video, as it was not found in storage.",
                );
            }
            try {
                console.log(`processing ${video.key} video with ai...`);
                const blob = await video.arrayBuffer();

                const input = {
                    audio: [...new Uint8Array(blob)],
                };

                const response = await this.env.AI.run(
                    "@cf/openai/whisper",
                    input,
                );
                console.log(response);
            } catch (e) {
                console.error(e);
                throw new NonRetryableError("Failed to process video with ai.");
            }
        });
    }
}

import {
    WorkflowEntrypoint,
    type WorkflowEvent,
    type WorkflowStep,
} from "cloudflare:workers";
import { NonRetryableError } from "cloudflare:workflows";
import type { FlipperBinding } from "@repo/types";

export type WorkflowVideoParams = {
    key: string;
};

export class WorkflowVideo extends WorkflowEntrypoint<
    FlipperBinding,
    WorkflowVideoParams
> {
    async run(event: WorkflowEvent<WorkflowVideoParams>, step: WorkflowStep) {
        // Can access bindings on `this.env`
        // Can access params on `event.payload`
        let video: R2ObjectBody | null;
        await step.do("getting video from R2", async () => {
            console.log("getting video from R2");
            video = await this.env.COVE_STORAGE.get(event.payload.key);
            if (!video) {
                throw new Error("Video not found in storage.");
            }
        });

        await step.do("ai video", async () => {
            if (!video) {
                throw new Error(
                    "Not processing video, as it was not found in storage.",
                );
            }
            try {
                console.log(`processing ${video.key} video with ai...`);
                const blob = await video.arrayBuffer();

                const input = {
                    audio: [...new Uint8Array(blob)],
                };

                const response = await this.env.AI.run(
                    "@cf/openai/whisper",
                    input,
                );
                console.log(response);
            } catch (e) {
                console.error(e);
                throw new NonRetryableError("Failed to process video with ai.");
            }
        });
    }
}