diff --git a/internal/extractors/pwextractor/pageparser.go b/internal/extractors/pwextractor/pageparser.go index 4ddf306..ef1a99e 100644 --- a/internal/extractors/pwextractor/pageparser.go +++ b/internal/extractors/pwextractor/pageparser.go @@ -64,6 +64,9 @@ func (p *pageParser) parse() (*models.TaskResult, error) { } result.Items = append(result.Items, item) } + if len(result.Items) == 0 { + return nil, fmt.Errorf("extract failed for all posts") + } return &result, nil } diff --git a/internal/extractors/pwextractor/pwextractor.go b/internal/extractors/pwextractor/pwextractor.go index ac3bc8e..4867b61 100644 --- a/internal/extractors/pwextractor/pwextractor.go +++ b/internal/extractors/pwextractor/pwextractor.go @@ -287,9 +287,6 @@ func (e *PwExtractor) Extract(task models.Task) (result *models.TaskResult, errR if err != nil { return fmt.Errorf("parse page: %w", err) } - if len(result.Items) == 0 { - return fmt.Errorf("extract failed for all posts") - } return nil }) return