Hotfix for airflow init

airflow/airflow.go

@@ -11,37 +11,17 @@ import (
 	"github.com/iancoleman/strcase"
 
 	"github.com/astronomerio/astro-cli/airflow/include"
+	"github.com/astronomerio/astro-cli/config"
 	"github.com/astronomerio/astro-cli/houston"
 	"github.com/astronomerio/astro-cli/pkg/fileutil"
 	"github.com/astronomerio/astro-cli/pkg/httputil"
-	"github.com/astronomerio/astro-cli/config"
 )
 
 var (
 	http = httputil.NewHTTPClient()
-	api = houston.NewHoustonClient(http)
+	api  = houston.NewHoustonClient(http)
 )
 
-func initProject(path string) {
-	// List of directories to create
-	dirs := []string{"dags", "plugins", "include"}
-
-	// Initailize directories
-	initDirs(path, dirs)
-
-	// Map of files to create
-	files := map[string]string{
-		".dockerignore":       include.Dockerignore,
-		"Dockerfile":          include.Dockerfile,
-		"packages.txt":        "",
-		"requirements.txt":    "",
-		"dags/example-dag.py": include.Exampledag,
-	}
-
-	// Initialize files
-	initFiles(path, files)
-}
-
 func initDirs(root string, dirs []string) bool {
 	// Any inputs exist
 	exists := false
@@ -91,28 +71,24 @@ func initFiles(root string, files map[string]string) bool {
 }
 
 // Init will scaffold out a new airflow project
-func Init(projectName string) error {
-	// Grab working directory
-	path := fileutil.GetWorkingDir()
-
-	projectName, err := validateOrCreateProjectName(path, projectName)
-	if err != nil {
-		return err
-	}
+func Init(path string) error {
+	// List of directories to create
+	dirs := []string{"dags", "plugins", "include"}
 
-	exists := config.ProjectConfigExists()
-	if !exists {
-		config.CreateProjectConfig(path)
+	// Map of files to create
+	files := map[string]string{
+		".dockerignore":       include.Dockerignore,
+		"Dockerfile":          include.Dockerfile,
+		"packages.txt":        "",
+		"requirements.txt":    "",
+		"dags/example-dag.py": include.Exampledag,
 	}
-	config.CFG.ProjectName.SetProjectString(projectName)
 
-	initProject(path)
+	// Initailize directories
+	initDirs(path, dirs)
 
-	if exists {
-		fmt.Printf("Reinitialized existing astronomer project in %s\n", path)
-	} else {
-		fmt.Printf("Initialized empty astronomer project in %s\n", path)
-	}
+	// Initialize files
+	initFiles(path, files)
 
 	return nil
 }

cmd/airflow.go

@@ -8,13 +8,13 @@ import (
 	"regexp"
 	"strings"
 
-	"github.com/spf13/cobra"
 	"github.com/iancoleman/strcase"
+	"github.com/spf13/cobra"
 
 	"github.com/astronomerio/astro-cli/airflow"
 	"github.com/astronomerio/astro-cli/config"
-	"github.com/astronomerio/astro-cli/pkg/git"
 	"github.com/astronomerio/astro-cli/pkg/fileutil"
+	"github.com/astronomerio/astro-cli/pkg/git"
 )
 
 var (