diff --git a/flyteadmin/pkg/rpc/adminservice/execution.go b/flyteadmin/pkg/rpc/adminservice/execution.go index 7b83ddf5ae9..35294dd711b 100644 --- a/flyteadmin/pkg/rpc/adminservice/execution.go +++ b/flyteadmin/pkg/rpc/adminservice/execution.go @@ -9,6 +9,7 @@ import ( "github.com/flyteorg/flyte/flyteadmin/pkg/rpc/adminservice/util" "github.com/flyteorg/flyte/flyteidl/gen/pb-go/flyteidl/admin" + "github.com/flyteorg/flyte/flytestdlib/logger" ) func (m *AdminService) CreateExecution( @@ -139,6 +140,10 @@ func (m *AdminService) GetExecutionData( return nil, util.TransformAndRecordError(err, &m.Metrics.executionEndpointMetrics.getData) } m.Metrics.executionEndpointMetrics.getData.Success() + // DEBUG: CASE-643 + if response.GetFullOutputs().GetLiterals() == nil || len(response.GetFullOutputs().GetLiterals()) == 0 { + logger.Debugf(ctx, "GetExecutionData().FullOutputs empty for execution %v. FullOutputs: %v. Outputs: %v", request.GetId(), response.GetFullOutputs(), response.GetOutputs()) + } return response, nil } diff --git a/flytepropeller/pkg/controller/nodes/subworkflow/launchplan.go b/flytepropeller/pkg/controller/nodes/subworkflow/launchplan.go index 67bcb57e083..8dfd9932625 100644 --- a/flytepropeller/pkg/controller/nodes/subworkflow/launchplan.go +++ b/flytepropeller/pkg/controller/nodes/subworkflow/launchplan.go @@ -210,6 +210,10 @@ func (l *launchPlanHandler) CheckLaunchPlanStatus(ctx context.Context, nCtx inte oInfo = &handler.OutputInfo{OutputURI: outputFile} } + // DEBUG: CASE-643 + if outputs.GetLiterals() == nil || len(outputs.GetLiterals()) == 0 { + logger.Debugf(ctx, "GetStatus() outputs empty for execution %v. Closure: %v. Outputs: %v", childID, wfStatusClosure, outputs) + } return handler.DoTransition(handler.TransitionTypeEphemeral, handler.PhaseInfoSuccess(&handler.ExecutionInfo{ WorkflowNodeInfo: &handler.WorkflowNodeInfo{LaunchedWorkflowID: childID},