From b716fbefedd813d35a7d21b07cab543310faf1c3 Mon Sep 17 00:00:00 2001
From: Piotr Mankowski <pmanko@uw.edu>
Date: Mon, 22 Jan 2024 18:36:54 -0800
Subject: [PATCH] fix (#99)

---
 src/workflows/botswana/workflowHandler.ts | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/src/workflows/botswana/workflowHandler.ts b/src/workflows/botswana/workflowHandler.ts
index 2574ee7..ec5295c 100644
--- 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
     }