From 72d5bce4a6818c63538e74a322ba02e530d23bdf Mon Sep 17 00:00:00 2001
From: Rohith BCS <rohithbcs@Rohiths-MacBook-Pro-2.local>
Date: Fri, 4 Oct 2024 12:01:58 +0530
Subject: [PATCH] fix: change retl check to source category

---
 router/worker.go | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/router/worker.go b/router/worker.go
index 61e8907141..c5823439d9 100644
--- a/router/worker.go
+++ b/router/worker.go
@@ -193,7 +193,7 @@ func (w *worker) workLoop() {
 				DestinationID: parameters.DestinationID,
 			}]
 			w.rt.destinationsMapMu.RUnlock()
-			if !destOK || (parameters.SourceJobRunID != "" && !connOK) {
+			if !destOK || (parameters.SourceCategory == "warehouse" && !connOK) {
 				continue
 			}
 			destination := batchDestination.Destination