File tree Expand file tree Collapse file tree
Expand file tree Collapse file tree Original file line number Diff line number Diff line change @@ -29,6 +29,7 @@ import (
2929
3030var (
3131 waitJobComplete = false
32+ jobName = "feastimport"
3233)
3334
3435// jobsCmd represents the jobs command
@@ -69,6 +70,7 @@ var jobsAbortCmd = &cobra.Command{
6970
7071func init () {
7172 jobsRunCmd .Flags ().BoolVar (& waitJobComplete , "wait" , false , "wait for job to run to completion" )
73+ jobsRunCmd .Flags ().StringVar (& jobName , "name" , "feastimport" , "job name to be submitted" )
7274 jobsCmd .AddCommand (jobsRunCmd )
7375 jobsCmd .AddCommand (jobsAbortCmd )
7476 rootCmd .AddCommand (jobsCmd )
@@ -86,6 +88,7 @@ func runJob(ctx context.Context, path string) error {
8688 initConn ()
8789 jobsClient := core .NewJobServiceClient (coreConn )
8890 out , err := jobsClient .SubmitJob (ctx , & core.JobServiceTypes_SubmitImportJobRequest {
91+ Name : jobName ,
8992 ImportSpec : is ,
9093 })
9194 if err != nil {
You can’t perform that action at this time.
0 commit comments