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