From 503d1be56eeca69b29606082905d8c3f3dbb86d7 Mon Sep 17 00:00:00 2001 From: Future Outlier Date: Wed, 6 Sep 2023 10:38:34 +0800 Subject: [PATCH] change PENDING return function PhaseInfoQueuedWithTaskInfo Signed-off-by: Future Outlier --- go/tasks/plugins/webapi/agent/plugin.go | 3 +-- 1 file changed, 1 insertion(+), 2 deletions(-) diff --git a/go/tasks/plugins/webapi/agent/plugin.go b/go/tasks/plugins/webapi/agent/plugin.go index 3417a5f5d..38222bb21 100644 --- a/go/tasks/plugins/webapi/agent/plugin.go +++ b/go/tasks/plugins/webapi/agent/plugin.go @@ -5,7 +5,6 @@ import ( "crypto/x509" "encoding/gob" "fmt" - "time" "github.com/flyteorg/flyteidl/gen/pb-go/flyteidl/admin" "github.com/flyteorg/flytestdlib/config" @@ -164,7 +163,7 @@ func (p Plugin) Status(ctx context.Context, taskCtx webapi.StatusContext) (phase switch resource.State { case admin.State_PENDING: - return core.PhaseInfoQueued(time.Now(), core.DefaultPhaseVersion, "Job Created"), nil + return core.PhaseInfoQueuedWithTaskInfo(core.DefaultPhaseVersion, "Job is PENDING", taskInfo), nil case admin.State_RUNNING: return core.PhaseInfoRunning(core.DefaultPhaseVersion, taskInfo), nil case admin.State_PERMANENT_FAILURE: