Fix dockerfile

proxy-renderer.js

@@ -41,7 +41,7 @@ function startChildProcess() {
 
 // start immediately
 startChildProcess();
-export const renderProxy = async (outFile, options) => {
+export const renderProxy = async (outFile, jobId, options) => {
   const ScriptStr = fs.readFileSync(originalManuScriptPath);
   const ScriptInput = JSON.parse(ScriptStr);
   let {
@@ -54,8 +54,12 @@ export const renderProxy = async (outFile, options) => {
   let framesRendered = 0;
   while (framesRendered < duration) {
     const endFrame = Math.min(framesRendered + framesPerChunk, duration);
-    const chunkOutFile = path.join(process.cwd(), `out/chunk-${framesRendered}-${endFrame}.mp4`);
-
+    const chunkOutFile = path.join(process.cwd(), `out/${jobId}-chunk-${framesRendered}-${endFrame}.mp4`);
+    if (fs.existsSync(chunkOutFile)) {
+      console.log(`Job ${jobId} chunk ${framesRendered}-${endFrame} already rendered. Skipping.`);
+      framesRendered = endFrame;
+      continue;
+    }
     let retryAttemptsLeft = options?.retry ?? 1
     while (retryAttemptsLeft >= 0) {
       try {
@@ -86,7 +90,7 @@ export const renderProxy = async (outFile, options) => {
   for (let i = 0; i < duration; i += framesPerChunk) {
     const chunkStart = i;
     const chunkEnd = Math.min(i + framesPerChunk, duration);
-    chunkFiles.push(path.join(process.cwd(), `out/chunk-${chunkStart}-${chunkEnd}.mp4`));
+    chunkFiles.push(path.join(process.cwd(), `out/${jobId}-chunk-${framesRendered}-${endFrame}.mp4`));
   }
 
   const ffmpegPath = os.platform() === 'win32' ? 'ffmpeg.exe' : 'ffmpeg';
@@ -95,6 +99,7 @@ export const renderProxy = async (outFile, options) => {
 
   const concatCmd = `${ffmpegPath} -f concat -safe 0 -i ${concatListPath} -c copy ${outFile}`;
   await new Promise((resolve, reject) => {
+    console.log('Stitching chunks...: ' + concatCmd)
     exec(concatCmd, (error, stdout, stderr) => {
       if (error) {
         console.error(`Error stitching chunks: ${error.message}`);

renderer.js

@@ -56,7 +56,7 @@ export async function doRender(jobId, composition, sendToObserver, target = 'ren
 		return outFile
 	}
 	else if (proxyOptions) {
-		await renderProxy(outFile, proxyOptions)
+		await renderProxy(outFile, jobId, proxyOptions)
 		sendToObserver(jobId, 'completed');
 		return outFile
 	}