dispatcher

Signed-off-by: Future Outlier <[email protected]>
flyteorg · Sep 27, 2023 · f06c395 · f06c395
1 parent 5b9852b
commit f06c395
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/go/tasks/pluginmachinery/internal/webapi/core.go b/go/tasks/pluginmachinery/internal/webapi/core.go
@@ -79,7 +79,7 @@ func (c CorePlugin) Handle(ctx context.Context, tCtx core.TaskExecutionContext)
 
 	taskTemplate, err := tCtx.TaskReader().Read(ctx)
 
-	if taskTemplate.Type == "requester" {
+	if taskTemplate.Type == "dispatcher" {
 		res, err := c.sp.Do(ctx, tCtx)
 		if err != nil {
 			return core.UnknownTransition, err

diff --git a/go/tasks/plugins/webapi/agent/plugin.go b/go/tasks/plugins/webapi/agent/plugin.go
@@ -126,7 +126,7 @@ func (p Plugin) Do(ctx context.Context, taskCtx webapi.TaskExecutionContextReade
 // we can get the task type in core.go
 /*
 taskTemplate, err := taskCtx.TaskReader().Read(ctx)
-taskTemplate.type = spark, requester ...
+taskTemplate.type = spark, dispatcher ...
 */
 func (p Plugin) Create(ctx context.Context, taskCtx webapi.TaskExecutionContextReader) (webapi.ResourceMeta,
 	webapi.Resource, error) {