From f84cabe7da1af04df7a31eb1b8bfacf382289476 Mon Sep 17 00:00:00 2001 From: Pradithya Aria Date: Fri, 29 Mar 2019 11:44:22 +0800 Subject: [PATCH] Add --name flag to submit job --- cli/feast/cmd/jobs.go | 3 +++ 1 file changed, 3 insertions(+) diff --git a/cli/feast/cmd/jobs.go b/cli/feast/cmd/jobs.go index 5eb3e401ce..8f44d9593e 100644 --- a/cli/feast/cmd/jobs.go +++ b/cli/feast/cmd/jobs.go @@ -29,6 +29,7 @@ import ( var ( waitJobComplete = false + jobName = "feastimport" ) // jobsCmd represents the jobs command @@ -69,6 +70,7 @@ var jobsAbortCmd = &cobra.Command{ func init() { jobsRunCmd.Flags().BoolVar(&waitJobComplete, "wait", false, "wait for job to run to completion") + jobsRunCmd.Flags().StringVar(&jobName, "name", "feastimport", "job name to be submitted") jobsCmd.AddCommand(jobsRunCmd) jobsCmd.AddCommand(jobsAbortCmd) rootCmd.AddCommand(jobsCmd) @@ -86,6 +88,7 @@ func runJob(ctx context.Context, path string) error { initConn() jobsClient := core.NewJobServiceClient(coreConn) out, err := jobsClient.SubmitJob(ctx, &core.JobServiceTypes_SubmitImportJobRequest{ + Name: jobName, ImportSpec: is, }) if err != nil {