diff --git a/flyteplugins/go/tasks/plugins/webapi/agent/plugin.go b/flyteplugins/go/tasks/plugins/webapi/agent/plugin.go index 1a5c879ead..7eeba19330 100644 --- a/flyteplugins/go/tasks/plugins/webapi/agent/plugin.go +++ b/flyteplugins/go/tasks/plugins/webapi/agent/plugin.go @@ -115,7 +115,7 @@ func (p Plugin) Create(ctx context.Context, taskCtx webapi.TaskExecutionContextR resource := ResourceWrapper{State: admin.State_RUNNING} // If the agent returned a resource, we assume this is a synchronous task. - // The state should be SUCCEEDED, PERMANENT_FAILURE or RETRYABLE_FAILURE. + // The state should be a terminal state, for example, SUCCEEDED, PERMANENT_FAILURE, or RETRYABLE_FAILURE. if res.GetResource() != nil { resource.State = res.GetResource().State resource.Outputs = res.GetResource().Outputs