diff --git a/packages/app/index.html b/packages/app/index.html index 90fb7119..d9c548e1 100644 --- a/packages/app/index.html +++ b/packages/app/index.html @@ -1,5 +1,5 @@ - +
diff --git a/packages/artisan/src/consumer/workers/transcode.ts b/packages/artisan/src/consumer/workers/transcode.ts index c1d4e412..db9e63ef 100644 --- a/packages/artisan/src/consumer/workers/transcode.ts +++ b/packages/artisan/src/consumer/workers/transcode.ts @@ -5,6 +5,7 @@ import { ffprobeQueue, ffmpegQueue } from "../../producer"; import { uploadJson } from "../s3"; import { assert } from "../../assert"; import { getDefaultAudioBitrate, getDefaultVideoBitrate } from "../../defaults"; +import { addPackageJob } from "../../producer"; import type { Input, PartialInput, Stream, PartialStream } from "../../types"; import type { Job } from "bullmq"; import type { FfprobeResult } from "./ffprobe"; @@ -62,6 +63,14 @@ export const transcodeCallback: WorkerCallback< case Step.Meta: { await handleStepMeta(job, token); + + if (job.data.packageAfter) { + await addPackageJob({ + assetId: job.data.assetId, + tag: job.data.tag, + }); + } + await job.updateData({ ...job.data, step: Step.Finish, diff --git a/packages/stitcher/src/vast.ts b/packages/stitcher/src/vast.ts index 680b69c9..be28aec2 100644 --- a/packages/stitcher/src/vast.ts +++ b/packages/stitcher/src/vast.ts @@ -15,7 +15,6 @@ export type AdMedia = { export async function getAdMediasFromVast(adBreak: VmapAdBreak) { const adMedias = await getAdMedias(adBreak); - const result: AdMedia[] = []; for (const adMedia of adMedias) {