This is an automated email from the ASF dual-hosted git repository.
arjun4084346 pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/gobblin.git
from 3a5496134 [GOBBLIN-2014] Add Temporal metadata tags to temporal parent
workflow for GaaS commu… (#3894)
add 2bdf7ebf3 [GOBBLIN-2015] implement LaunchDagProc to handle new dag
launches (#3893)
No new revisions were added by this update.
Summary of changes:
.../modules/core/GobblinServiceManager.java | 3 -
.../orchestration/DagManagementStateStore.java | 5 +
.../orchestration/DagManagementTaskStreamImpl.java | 2 -
.../service/modules/orchestration/DagManager.java | 2 -
.../modules/orchestration/DagManagerMetrics.java | 4 +-
.../modules/orchestration/DagProcFactory.java | 12 +-
.../modules/orchestration/DagProcessingEngine.java | 2 +-
.../MostlyMySqlDagManagementStateStore.java | 6 +-
.../modules/orchestration/proc/DagProc.java | 4 +
.../modules/orchestration/proc/LaunchDagProc.java | 163 ++++++++++++++++++---
.../utils/FlowCompilationValidationHelper.java | 2 +-
.../DagManagementTaskStreamImplTest.java | 2 +-
.../modules/orchestration/DagManagerTest.java | 2 +-
.../orchestration/DagProcessingEngineTest.java | 32 ++--
.../MostlyMySqlDagManagementStateStoreTest.java | 42 +++---
.../orchestration/proc/LaunchDagProcTest.java | 128 ++++++++++++++++
16 files changed, 341 insertions(+), 70 deletions(-)
create mode 100644
gobblin-service/src/test/java/org/apache/gobblin/service/modules/orchestration/proc/LaunchDagProcTest.java
