From 5b05851442e2a40aeef268b3c3128eaaa1d3043c Mon Sep 17 00:00:00 2001
From: Urmi Mustafi <umustafi@umustafi-mn1.linkedin.biz>
Date: Mon, 10 Jul 2023 10:04:39 -0700
Subject: [PATCH] [GOBBLIN-1849] Add Flow Group & Name to Job Config for Job
 Scheduler

---
 .../modules/scheduler/GobblinServiceJobScheduler.java      | 7 +++++++
 1 file changed, 7 insertions(+)

diff --git a/gobblin-service/src/main/java/org/apache/gobblin/service/modules/scheduler/GobblinServiceJobScheduler.java b/gobblin-service/src/main/java/org/apache/gobblin/service/modules/scheduler/GobblinServiceJobScheduler.java
index 5e0ac398840..d860ed48587 100644
--- a/gobblin-service/src/main/java/org/apache/gobblin/service/modules/scheduler/GobblinServiceJobScheduler.java
+++ b/gobblin-service/src/main/java/org/apache/gobblin/service/modules/scheduler/GobblinServiceJobScheduler.java
@@ -677,6 +677,13 @@ private Properties createJobConfig(FlowSpec flowSpec) {
           flowSpecProperties.getProperty(ConfigurationKeys.JOB_SCHEDULE_KEY));
     }
 
+    // Note: the default values for missing flow name/group are different than the ones above to easily identify where
+    // the values are not present initially
+    jobConfig.setProperty(ConfigurationKeys.FLOW_NAME_KEY,
+        flowSpecProperties.getProperty(ConfigurationKeys.FLOW_NAME_KEY, "<<missing flow name>>"));
+    jobConfig.setProperty(ConfigurationKeys.FLOW_GROUP_KEY,
+        flowSpecProperties.getProperty(ConfigurationKeys.FLOW_GROUP_KEY, "<<missing flow group>>"));
+
     return jobConfig;
   }