(gobblin) branch master updated: disable dag manager code when dag proc engine is enabled (#3977)

[arjun4084346]

This is an automated email from the ASF dual-hosted git repository.

arjun4084346 pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/gobblin.git


The following commit(s) were added to refs/heads/master by this push:
     new 0d4ee241b disable dag manager code when dag proc engine is enabled 
(#3977)
0d4ee241b is described below

commit 0d4ee241bef8d68f257f91ebd878e0b39698f68c
Author: Arjun Singh Bora <ab...@linkedin.com>
AuthorDate: Mon Jun 17 16:22:26 2024 -0700

    disable dag manager code when dag proc engine is enabled (#3977)
---
 .../apache/gobblin/service/modules/core/GobblinServiceManager.java  | 6 ++++--
 1 file changed, 4 insertions(+), 2 deletions(-)

diff --git 
a/gobblin-service/src/main/java/org/apache/gobblin/service/modules/core/GobblinServiceManager.java
 
b/gobblin-service/src/main/java/org/apache/gobblin/service/modules/core/GobblinServiceManager.java
index 827ac961e..ba6d4f0c4 100644
--- 
a/gobblin-service/src/main/java/org/apache/gobblin/service/modules/core/GobblinServiceManager.java
+++ 
b/gobblin-service/src/main/java/org/apache/gobblin/service/modules/core/GobblinServiceManager.java
@@ -368,8 +368,10 @@ public class GobblinServiceManager implements 
ApplicationLauncher, StandardMetri
           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();