umustafi commented on code in PR #3973:
URL: https://github.com/apache/gobblin/pull/3973#discussion_r1642990758
##########
gobblin-service/src/main/java/org/apache/gobblin/service/modules/orchestration/proc/DagProcUtils.java:
##########
@@ -210,4 +211,36 @@ public static long getDefaultJobStartDeadline(Config
config) {
return jobStartTimeUnit.toMillis(ConfigUtils.getLong(config,
DagManager.JOB_START_SLA_TIME,
ConfigurationKeys.FALLBACK_GOBBLIN_JOB_START_SLA_TIME));
}
+
+ public static boolean isJobLevelStatus(String jobName) {
+ return !jobName.equals(JobStatusRetriever.NA_KEY);
+ }
+
+ public static void
removeEnforceJobStartDeadlineDagAction(DagManagementStateStore
dagManagementStateStore, String flowGroup,
+ String flowName, long flowExecutionId, String jobName) {
+ DagActionStore.DagAction enforceJobStartDeadlineDagAction = new
DagActionStore.DagAction(flowGroup, flowName,
+ flowExecutionId, jobName,
DagActionStore.DagActionType.ENFORCE_JOB_START_DEADLINE);
+ log.info("Deleting {}", enforceJobStartDeadlineDagAction);
Review Comment:
"Deleting dag action {}" (easier to find)
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
