feat(prism-agent): Add prism agent record processing pipeline paramet…

…ers (#626) Signed-off-by: Shota Jolbordi <[email protected]>
hyperledger · Aug 17, 2023 · 434bdac · 434bdac
1 parent 6fdff98
commit 434bdac
Showing 1 changed file with 9 additions and 0 deletions.
diff --git a/prism-agent/service/server/src/main/resources/application.conf b/prism-agent/service/server/src/main/resources/application.conf
@@ -50,11 +50,17 @@ pollux {
     awaitConnectionThreads = 8
   }
   issueBgJobRecordsLimit = 25
+  issueBgJobRecordsLimit = ${?ISSUE_BG_JOB_RECORDS_LIMIT}
   issueBgJobRecurrenceDelay = 2 seconds
+  issueBgJobRecurrenceDelay = ${?ISSUE_BG_JOB_RECURRENCE_DELAY}
   issueBgJobProcessingParallelism = 5
+  issueBgJobProcessingParallelism = ${?ISSUE_BG_JOB_PROCESSING_PARALLELISM}
   presentationBgJobRecordsLimit = 25
+  presentationBgJobRecordsLimit = ${?PRESENTATION_BG_JOB_RECORDS_LIMIT}
   presentationBgJobRecurrenceDelay = 2 seconds
+  presentationBgJobRecurrenceDelay = ${?PRESENTATION_BG_JOB_RECURRENCE_DELAY}
   presentationBgJobProcessingParallelism = 5
+  presentationBgJobProcessingParallelism = ${?PRESENTATION_BG_JOB_PROCESSING_PARALLELISM}
 }
 
 connect {
@@ -72,8 +78,11 @@ connect {
     awaitConnectionThreads = 8
   }
   connectBgJobRecordsLimit = 25
+  connectBgJobRecordsLimit = ${?CONNECT_BG_JOB_RECORDS_LIMIT}
   connectBgJobRecurrenceDelay = 2 seconds
+  connectBgJobRecurrenceDelay = ${?CONNECT_BG_JOB_RECURRENCE_DELAY}
   connectBgJobProcessingParallelism = 5
+  connectBgJobProcessingParallelism = ${?CONNECT_BG_JOB_PROCESSING_PARALLELISM}
 }
 
 agent {