From 65ff49fedf4a5d01177dbfac25b41f6fa57a0e0a Mon Sep 17 00:00:00 2001 From: Greg <2653109+glinton@users.noreply.github.com> Date: Mon, 15 Aug 2022 10:19:09 -0600 Subject: [PATCH] chore(tasks): support looking up tasks by script id (#437) --- api/api_tasks.gen.go | 12 ++++++++++++ api/contract/openapi | 2 +- clients/task/task.go | 10 +++++++--- cmd/influx/task.go | 5 +++++ 4 files changed, 25 insertions(+), 4 deletions(-) diff --git a/api/api_tasks.gen.go b/api/api_tasks.gen.go index 50a9b89..08ed4f4 100644 --- a/api/api_tasks.gen.go +++ b/api/api_tasks.gen.go @@ -701,6 +701,7 @@ type ApiGetTasksRequest struct { offset *int32 sortBy *string type_ *string + scriptID *string } func (r ApiGetTasksRequest) ZapTraceSpan(zapTraceSpan string) ApiGetTasksRequest { @@ -791,6 +792,14 @@ func (r ApiGetTasksRequest) GetType_() *string { return r.type_ } +func (r ApiGetTasksRequest) ScriptID(scriptID string) ApiGetTasksRequest { + r.scriptID = &scriptID + return r +} +func (r ApiGetTasksRequest) GetScriptID() *string { + return r.scriptID +} + func (r ApiGetTasksRequest) Execute() (Tasks, error) { return r.ApiService.GetTasksExecute(r) } @@ -882,6 +891,9 @@ func (a *TasksApiService) GetTasksExecuteWithHttpInfo(r ApiGetTasksRequest) (Tas if r.type_ != nil { localVarQueryParams.Add("type", parameterToString(*r.type_, "")) } + if r.scriptID != nil { + localVarQueryParams.Add("scriptID", parameterToString(*r.scriptID, "")) + } // to determine the Content-Type header localVarHTTPContentTypes := []string{} diff --git a/api/contract/openapi b/api/contract/openapi index 0df6358..226874d 160000 --- a/api/contract/openapi +++ b/api/contract/openapi @@ -1 +1 @@ -Subproject commit 0df6358a78262bcf33edd35bb242dce2a9744ea1 +Subproject commit 226874df6889b39e3e0794585b7eafaa70e2f8b1 diff --git a/clients/task/task.go b/clients/task/task.go index c5c1cd7..f03ad81 100644 --- a/clients/task/task.go +++ b/clients/task/task.go @@ -109,9 +109,10 @@ func (c Client) Create(ctx context.Context, params *CreateParams) error { type FindParams struct { clients.OrgParams - TaskID string - UserID string - Limit int + TaskID string + UserID string + ScriptID string + Limit int } func (c Client) Find(ctx context.Context, params *FindParams) error { @@ -141,6 +142,9 @@ func (c Client) Find(ctx context.Context, params *FindParams) error { if params.UserID != "" { getTask = getTask.User(params.UserID) } + if params.ScriptID != "" { + getTask = getTask.ScriptID(params.ScriptID) + } tasksResult, err := getTask.Execute() if err != nil { return err diff --git a/cmd/influx/task.go b/cmd/influx/task.go index 6614122..9eeae40 100644 --- a/cmd/influx/task.go +++ b/cmd/influx/task.go @@ -125,6 +125,11 @@ func newTaskFindCmd() cli.Command { Usage: "task owner ID", Destination: ¶ms.UserID, }, + &cli.StringFlag{ + Name: "script-id", + Usage: "script ID", + Destination: ¶ms.ScriptID, + }, &cli.IntFlag{ Name: "limit", Usage: "the number of tasks to find",