diff --git a/gobblin-temporal/src/main/java/org/apache/gobblin/temporal/util/nesting/workflow/AbstractNestingExecWorkflowImpl.java b/gobblin-temporal/src/main/java/org/apache/gobblin/temporal/util/nesting/workflow/AbstractNestingExecWorkflowImpl.java index 425d6284c37..0dcf19a779d 100644 --- a/gobblin-temporal/src/main/java/org/apache/gobblin/temporal/util/nesting/workflow/AbstractNestingExecWorkflowImpl.java +++ b/gobblin-temporal/src/main/java/org/apache/gobblin/temporal/util/nesting/workflow/AbstractNestingExecWorkflowImpl.java @@ -118,6 +118,7 @@ protected NestingExecWorkflow createChildWorkflow(final WorkflowAddr /** @return how long to pause prior to creating a child workflow, based on `numDirectLeavesChildMayHave` */ protected Duration calcPauseDurationBeforeCreatingSubTree(int numDirectLeavesChildMayHave) { // (only pause when an appreciable number of leaves) + // TODO: use a configuration value, for simpler adjustment, rather than hard-code return numDirectLeavesChildMayHave > MAX_CHILD_SUB_TREE_LEAVES_BEFORE_SHOULD_PAUSE_DEFAULT ? Duration.ofSeconds(NUM_SECONDS_TO_PAUSE_BEFORE_CREATING_SUB_TREE_DEFAULT) : Duration.ZERO;