feat: cancellable jobs commands

internal/cmd/jobs/get.go

@@ -36,11 +36,11 @@ func GetCommand() *cobra.Command {
 				_ = tracker.Close()
 			}()
 		},
-		RunE: func(_ *cobra.Command, args []string) error {
+		RunE: func(cmd *cobra.Command, args []string) error {
 			if out != JSONOutput && out != TextOutput {
 				return errors.New("unknown output format")
 			}
-			return get(args[0], out)
+			return get(cmd.Context(), args[0], out)
 		},
 	}
 	flags := cmd.PersistentFlags()
@@ -49,8 +49,8 @@ func GetCommand() *cobra.Command {
 	return cmd
 }
 
-func get(jobID, outputFormat string) error {
-	j, err := jobService.ReadJob(context.Background(), jobID)
+func get(ctx context.Context, jobID, outputFormat string) error {
+	j, err := jobService.ReadJob(ctx, jobID)
 	if err != nil {
 		return fmt.Errorf("failed to get job: %w", err)
 	}

internal/cmd/jobs/list.go

@@ -86,7 +86,7 @@ func ListCommand() *cobra.Command {
 				_ = tracker.Close()
 			}()
 		},
-		RunE: func(_ *cobra.Command, _ []string) error {
+		RunE: func(cmd *cobra.Command, _ []string) error {
 			if page < 0 {
 				return errors.New("invalid page")
 			}
@@ -112,7 +112,7 @@ func ListCommand() *cobra.Command {
 				return errors.New("invalid job resource. Options: vdc, rdc, api")
 			}
 
-			return list(out, page, size, status, job.Source(jobSource))
+			return list(cmd.Context(), out, page, size, status, job.Source(jobSource))
 		},
 	}
 	flags := cmd.PersistentFlags()
@@ -125,8 +125,8 @@ func ListCommand() *cobra.Command {
 	return cmd
 }
 
-func list(format string, page int, size int, status string, source job.Source) error {
-	user, err := userService.User(context.Background())
+func list(ctx context.Context, format string, page int, size int, status string, source job.Source) error {
+	user, err := userService.User(ctx)
 	if err != nil {
 		return fmt.Errorf("failed to get user: %w", err)
 	}
@@ -139,7 +139,7 @@ func list(format string, page int, size int, status string, source job.Source) e
 		Source: source,
 	}
 
-	jobs, err := jobService.ListJobs(context.Background(), opts)
+	jobs, err := jobService.ListJobs(ctx, opts)
 	if err != nil {
 		return fmt.Errorf("failed to get jobs: %w", err)
 	}