fix (#99)

I-TECH-UW · Jan 23, 2024 · b716fbe · b716fbe
1 parent ee2e329
commit b716fbe
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/src/workflows/botswana/workflowHandler.ts b/src/workflows/botswana/workflowHandler.ts
@@ -103,7 +103,7 @@ export class WorkflowHandler {
 
   // Initialize Kafka producer when the class is first used.
   public static async initKafkaProducer() {
-    if (!this.kafkaProducerInitialized) {
+    if (!this.kafkaProducerInitialized && config.get('taskRunner:brokers')) {
       await this.kafka.init()
       this.kafkaProducerInitialized = true
     }