diff --git a/internal/batch/workflow.go b/internal/batch/workflow.go index 02e96116..cb1cbe47 100644 --- a/internal/batch/workflow.go +++ b/internal/batch/workflow.go @@ -84,15 +84,15 @@ func (a *BatchActivity) Execute(ctx context.Context, params BatchWorkflowInput) return nil // Ignore root. } - if strings.HasPrefix(filepath.Base(path), ".") { - return nil // Ignore hidden files - } - depth := len(strings.Split(rel, string(filepath.Separator))) - 1 if depth != int(params.Depth) { return nil // Keep walking. } + if strings.HasPrefix(filepath.Base(path), ".") && !entry.IsDir() { + return nil // Ignore hidden files. + } + req := collection.ProcessingWorkflowRequest{ BatchDir: filepath.Dir(path), Key: entry.Name(),