feat: terminate the job as well when fail to fetch log

goto · Sep 30, 2024 · aea3c6f · aea3c6f
1 parent a5a458a
commit aea3c6f
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/max2max/internal/client/odps.go b/max2max/internal/client/odps.go
@@ -35,6 +35,7 @@ func (c *odpsClient) ExecSQL(ctx context.Context, query string) error {
 	// generate log view
 	url, err := odps.NewLogView(c.client).GenerateLogView(taskIns, 1)
 	if err != nil {
+		err = e.Join(err, taskIns.Terminate())
 		return errors.WithStack(err)
 	}
 	c.logger.Info(fmt.Sprintf("log view: %s", url))