Do not panic and return exit code 0 even when errors happened

cmd/root.go

@@ -54,7 +54,7 @@ var collectCmd = &cobra.Command{
 		})
 		if err != nil {
 			fmt.Println(err)
-			os.Exit(1)
+			os.Exit(0)
 		}
 	},
 }
@@ -88,7 +88,7 @@ var uploadCmd = &cobra.Command{
 		})
 		if err != nil {
 			fmt.Println(err)
-			os.Exit(1)
+			os.Exit(0)
 		}
 	},
 }
@@ -111,18 +111,18 @@ var uploadAuditCmd = &cobra.Command{
 			err := sqlmesh.CollectAuditLog(output, fileArg)
 			if err != nil {
 				logrus.WithError(err).Error("Failed to collect audit log")
-				os.Exit(1)
+				os.Exit(0)
 			}
 		}
 
 		if SynqApiToken == "" {
 			logrus.Error("SYNQ_TOKEN environment variable is not set")
-			os.Exit(1)
+			os.Exit(0)
 		}
 
 		if err := synq.UploadExecutionLog(cmd.Context(), output, SynqApiEndpoint, SynqApiToken); err != nil {
 			logrus.WithError(err).Error("Failed to upload execution log")
-			os.Exit(1)
+			os.Exit(0)
 		}
 	},
 }
@@ -145,18 +145,18 @@ var uploadRunCmd = &cobra.Command{
 			err := sqlmesh.CollectAuditLog(output, fileArg)
 			if err != nil {
 				logrus.WithError(err).Error("Failed to collect audit log")
-				os.Exit(1)
+				os.Exit(0)
 			}
 		}
 
 		if SynqApiToken == "" {
 			logrus.Error("SYNQ_TOKEN environment variable is not set")
-			os.Exit(1)
+			os.Exit(0)
 		}
 
 		if err := synq.UploadExecutionLog(cmd.Context(), output, SynqApiEndpoint, SynqApiToken); err != nil {
 			logrus.WithError(err).Error("Failed to upload execution log")
-			os.Exit(1)
+			os.Exit(0)
 		}
 	},
 }

main.go

@@ -17,7 +17,7 @@ func main() {
 
 	if err := cmd.Execute(); err != nil {
 		logrus.WithError(err).Error("Error executing command")
-		os.Exit(1)
+		os.Exit(0)
 	}
 	os.Exit(0)
 }

process/helpers.go

@@ -52,12 +52,12 @@ func ExecuteCommand(ctx context.Context, cmdName string, args []string, opts ...
 	stdOutReader, err := cmd.StdoutPipe()
 	if err != nil {
 		fmt.Fprintln(os.Stderr, "error creating StdoutPipe for Cmd", err)
-		os.Exit(1)
+		os.Exit(0)
 	}
 	stdErrReader, err := cmd.StderrPipe()
 	if err != nil {
 		fmt.Fprintln(os.Stderr, "error creating StderrPipe for Cmd", err)
-		os.Exit(1)
+		os.Exit(0)
 	}
 
 	var outb, errb bytes.Buffer

sqlmesh/health.go

@@ -21,5 +21,5 @@ func WaitForSQLMeshToStart(url url.URL) {
 		time.Sleep(1 * time.Second)
 	}
 	logrus.Error("SQLMesh did not start in time")
-	os.Exit(1)
+	os.Exit(0)
 }

synq/synq.go

@@ -74,7 +74,7 @@ func UploadMetadata(ctx context.Context, output *ingestsqlmeshv1.IngestMetadataR
 
 	oauthTokenSource, err := LongLivedTokenSource(token, parsedEndpoint)
 	if err != nil {
-		panic(err)
+		return err
 	}
 	creds := credentials.NewTLS(&tls.Config{InsecureSkipVerify: false})
 	opts := []grpc.DialOption{
@@ -85,7 +85,7 @@ func UploadMetadata(ctx context.Context, output *ingestsqlmeshv1.IngestMetadataR
 
 	conn, err := grpc.DialContext(ctx, grpcEndpoint(parsedEndpoint), opts...)
 	if err != nil {
-		panic(err)
+		return err
 	}
 	defer conn.Close()
 
@@ -106,7 +106,7 @@ func UploadExecutionLog(ctx context.Context, output *ingestsqlmeshv1.IngestExecu
 
 	oauthTokenSource, err := LongLivedTokenSource(token, parsedEndpoint)
 	if err != nil {
-		panic(err)
+		return err
 	}
 	creds := credentials.NewTLS(&tls.Config{InsecureSkipVerify: false})
 	opts := []grpc.DialOption{
@@ -117,7 +117,7 @@ func UploadExecutionLog(ctx context.Context, output *ingestsqlmeshv1.IngestExecu
 
 	conn, err := grpc.DialContext(ctx, grpcEndpoint(parsedEndpoint), opts...)
 	if err != nil {
-		panic(err)
+		return err
 	}
 	defer conn.Close()