|
|
@ -44,8 +44,6 @@ type Pipeline struct { |
|
|
|
} |
|
|
|
|
|
|
|
func (p Pipeline) Run(srcPath, bucketName string, storageProvider storage.IStorageProvider) (string, error) { |
|
|
|
fmt.Println("path: ", storageProvider.GetPath(bucketName, srcPath)) |
|
|
|
|
|
|
|
src, err := imaging.Open(storageProvider.GetPath(bucketName, srcPath)) |
|
|
|
if err != nil { |
|
|
|
return "", errors.New(fmt.Sprintf("error opening file for processing: %s", err)) |
|
|
@ -134,7 +132,6 @@ func LoadPipelines() []IPipeline { |
|
|
|
|
|
|
|
err := filepath.Walk(path+"/config", func(path string, info fs.FileInfo, err error) error { |
|
|
|
if err == nil && info.IsDir() == false { |
|
|
|
fmt.Println(path) |
|
|
|
data, _ := os.ReadFile(path) |
|
|
|
files = append(files, data) |
|
|
|
} |
|
|
|