Removing some debug statements (flyteorg#81)

eapolinario · Apr 24, 2020 · 63088b6 · 63088b6
1 parent 7361bf6
commit 63088b6
Show file tree

Hide file tree

Showing 2 changed files with 0 additions and 4 deletions.
diff --git a/go/tasks/plugins/array/awsbatch/launcher.go b/go/tasks/plugins/array/awsbatch/launcher.go
@@ -17,7 +17,6 @@ import (
 
 func LaunchSubTasks(ctx context.Context, tCtx core.TaskExecutionContext, batchClient Client, pluginConfig *config.Config,
 	currentState *State, metrics ExecutorMetrics) (nextState *State, err error) {
-	logger.Debugf(ctx, "Entering LaunchSubTasks ")
 	size := currentState.GetExecutionArraySize()
 	if int64(currentState.GetExecutionArraySize()) > pluginConfig.MaxArrayJobSize {
 		ee := fmt.Errorf("array size > max allowed. Requested [%v]. Allowed [%v]", currentState.GetExecutionArraySize(), pluginConfig.MaxArrayJobSize)
@@ -54,8 +53,6 @@ func LaunchSubTasks(ctx context.Context, tCtx core.TaskExecutionContext, batchCl
 	}
 
 	metrics.SubTasksSubmitted.Add(ctx, float64(size))
-	logger.Debugf(ctx, "BatchTasks submitted")
-
 	parentState := currentState.
 		SetPhase(arrayCore.PhaseCheckingSubTaskExecutions, 0).
 		SetArrayStatus(arraystatus.ArrayStatus{

diff --git a/go/tasks/plugins/array/awsbatch/monitor.go b/go/tasks/plugins/array/awsbatch/monitor.go
@@ -36,7 +36,6 @@ func createSubJobList(count int) []*Job {
 
 func CheckSubTasksState(ctx context.Context, taskMeta core.TaskExecutionMetadata, outputPrefix, baseOutputSandbox storage.DataReference, jobStore *JobStore,
 	dataStore *storage.DataStore, cfg *config.Config, currentState *State, metrics ExecutorMetrics) (newState *State, err error) {
-	logger.Debugf(ctx, "Entering CheckSubTasksState ")
 	newState = currentState
 	parentState := currentState.State
 	jobName := taskMeta.GetTaskExecutionID().GetGeneratedName()