Load configs and directories from the working directory (#1952)

* Load configuration and needed directories from the working directory * update check --------- Co-authored-by: Raúl Barroso <[email protected]>
ConduitIO · Nov 8, 2024 · 55ebed9 · 55ebed9
1 parent 977b037
commit 55ebed9
Show file tree

Hide file tree

Showing 2 changed files with 8 additions and 6 deletions.
diff --git a/cmd/cli/pipelines_init.go b/cmd/cli/pipelines_init.go
@@ -186,10 +186,7 @@ func (pi *PipelinesInit) Run() error {
 
 	fmt.Printf(`Your pipeline has been initialized and created at %s.
 
-To run the pipeline, execute:
-
-conduit --pipelines.path %s`,
-		pi.configFilePath(), pi.configFilePath())
+To run the pipeline, simply run 'conduit'.`, pi.configFilePath())
 
 	return nil
 }

diff --git a/pkg/conduit/config.go b/pkg/conduit/config.go
@@ -125,7 +125,12 @@ type Config struct {
 }
 
 func DefaultConfig() Config {
-	return DefaultConfigWithBasePath(".")
+	dir, err := os.Getwd()
+	if err != nil {
+		panic(cerrors.Errorf("failed to get current directory: %w", err))
+	}
+
+	return DefaultConfigWithBasePath(dir)
 }
 
 func DefaultConfigWithBasePath(basePath string) Config {
@@ -273,7 +278,7 @@ func (c Config) Validate() error {
 	}
 	// check if folder exists
 	_, err = os.Stat(c.Pipelines.Path)
-	if c.Pipelines.Path != "pipelines" && os.IsNotExist(err) {
+	if c.Pipelines.Path != DefaultConfig().Pipelines.Path && os.IsNotExist(err) {
 		return invalidConfigFieldErr("pipelines.path")
 	}