config variables for delays

Eyevinn · Oct 13, 2023 · 5aeeb8a · 5aeeb8a
1 parent fec6886
commit 5aeeb8a
Show file tree

Hide file tree

Showing 3 changed files with 10 additions and 3 deletions.
diff --git a/examples/encoreExample.ts b/examples/encoreExample.ts
@@ -1,6 +1,8 @@
 import { EncorePipelineConfiguration } from '../src/pipelines/encore/encore-pipeline-configuration';
 import { EncorePipeline, delay } from '../src/pipelines/encore/encore-pipeline';
 import { EncoreInstance } from '../src/models/encoreInstance';
+import path from 'path';
+import fs from 'fs';
 
 async function transcodeInputsAndAnalyze() {
 
@@ -14,6 +16,8 @@ async function transcodeInputsAndAnalyze() {
       inputs: ["https://testcontent.eyevinn.technology/mp4/stswe-tvplus-promo.mp4"],
       duration: 120,
       priority: 0,
+      encorePollingInterval_ms: 30000,
+      encoreInstancePostCreationDelay_ms: 10000
     };  
 
     const pipeline: EncorePipeline = new EncorePipeline(configuration);

diff --git a/src/pipelines/encore/encore-pipeline-configuration.ts b/src/pipelines/encore/encore-pipeline-configuration.ts
@@ -8,4 +8,6 @@ export type EncorePipelineConfiguration = {
     inputs: Array<string>;
     duration: number;
     priority: number;
+    encorePollingInterval_ms: number;
+    encoreInstancePostCreationDelay_ms: number
   };
diff --git a/src/pipelines/encore/encore-pipeline.ts b/src/pipelines/encore/encore-pipeline.ts
@@ -205,7 +205,7 @@ export class EncorePipeline implements Pipeline {
           enqueuedJobIds.splice(jobShouldBeProcessed, 1);
         }
       }
-      await delay(30000);
+      await delay(this.configuration.encorePollingInterval_ms);
     }
   }
 
@@ -294,7 +294,6 @@ export class EncorePipeline implements Pipeline {
 
     let jobIds: string[] = [];
     let references: string[] = [];
-    await delay(10000); // Delay required to allow instance to be created before calling it
 
     for (let input of this.configuration.inputs) {
       const job: EncoreJob = await this.createEncoreJob(instance, input);
@@ -327,6 +326,8 @@ async function dummymain() {
     inputs: ["https://testcontent.eyevinn.technology/mp4/stswe-tvplus-promo.mp4"],
     duration: 120,
     priority: 0,
+    encorePollingInterval_ms: 30000,
+    encoreInstancePostCreationDelay_ms: 10000
   };
 
   const AWSConf: AWSPipelineConfiguration = {
@@ -348,7 +349,7 @@ async function dummymain() {
   const pipeline: EncorePipeline = new EncorePipeline(configuration);
   const instance: EncoreInstance = await pipeline.createEncoreInstance(configuration.apiAddress, configuration.token, configuration.instanceId, configuration.profile);
   let jobIds: string[] = [];
-  await delay(10000);
+  await delay(pipeline.configuration.encoreInstancePostCreationDelay_ms);
   for (let input of configuration.inputs) {
     const job: EncoreJob = await pipeline.createEncoreJob(instance, input);
     jobIds.push(job.id);