disable dag manager code when dag proc engine is enabled (apache#3977)

umustafi · Jun 17, 2024 · 0d4ee24 · 0d4ee24
1 parent c064604
commit 0d4ee24
Showing 1 changed file with 4 additions and 2 deletions.
diff --git a/...-service/src/main/java/org/apache/gobblin/service/modules/core/GobblinServiceManager.java b/...-service/src/main/java/org/apache/gobblin/service/modules/core/GobblinServiceManager.java
@@ -368,8 +368,10 @@ private void handleLeadershipChange(NotificationContext changeContext) {
           this.gitConfigMonitor.setActive(false);
         }
 
-        this.dagManager.setActive(false);
-        this.eventBus.unregister(this.dagManager);
+        if (!this.configuration.isDagProcessingEngineEnabled()) {
+          this.dagManager.setActive(false);
+          this.eventBus.unregister(this.dagManager);
+        }
 
         if (configuration.isOnlyAnnounceLeader()) {
           this.d2Announcer.markDownServer();