```ruby
namespace :headlines do
  namespace :domains do
    DOMAINS_CATEGORIES = <<-SQL
      SELECT DISTINCT unnest(array_accum(parents)) parents
        FROM headlines_categories,
        LATERAL (
          SELECT domain_name, category_id AS id
            FROM headlines_domains_categories
            WHERE domain_name = '%{domain_name}'
        ) categories
        WHERE headlines_categories.parents && ARRAY[categories.id]
        GROUP BY categories.domain_name;
    SQL

    def domain_categories(domain_name)
      Headlines::Domain.connection.execute(
        DOMAINS_CATEGORIES % { domain_name: domain_name }
      ).values.flatten
    end

    desc "Refresh list of categories for each domain"
    task refresh_categories: :environment do
      puts "Collect categories for each domain"
      Headlines::Domain.connection.execute(<<-SQL)
        DROP AGGREGATE IF EXISTS array_accum(anyarray);
        CREATE AGGREGATE array_accum(anyarray)
        (sfunc = array_cat, stype = anyarray, initcond = '{}');
      SQL

      progressbar = ProgressBar.create(total: Headlines::Domain.count, format: "%a %e %P% Processed: %c from %C")
      Headlines::Domain.find_each do |domain|
        domain.update_attributes(parent_category_ids: domain_categories(domain.name))
        Rails.logger.info("Domain categories: #{domain.name} completed.")
        progressbar.increment
      end

      Headlines::Domain.connection.execute("DROP AGGREGATE IF EXISTS array_accum(anyarray)")
    end
  end
end
```

Fix caollecting domain parent categories
user
```ruby
namespace :headlines do
  namespace :domains do
    DOMAINS_CATEGORIES = <<-SQL
      SELECT DISTINCT unnest(array_accum(parents)) parents
      FROM headlines_categories
      INNER JOIN headlines_domains_categories
      ON headlines_categories.id = headlines_domains_categories.category_id
      WHERE headlines_domains_categories.domain_name = '%{domain_name}';
    SQL

    def domain_categories(domain_name)
      Headlines::Domain.connection.execute(
        DOMAINS_CATEGORIES % { domain_name: domain_name }
      ).values.flatten
    end

    desc "Refresh list of categories for each domain"
    task refresh_categories: :environment do
      puts "Collect categories for each domain"
      Headlines::Domain.connection.execute(<<-SQL)
        DROP AGGREGATE IF EXISTS array_accum(anyarray);
        CREATE AGGREGATE array_accum(anyarray)
        (sfunc = array_cat, stype = anyarray, initcond = '{}');
      SQL

      progressbar = ProgressBar.create(total: Headlines::Domain.count, format: "%a %e %P% Processed: %c from %C")
      Headlines::Domain.find_each do |domain|
        domain.update_attributes(parent_category_ids: domain_categories(domain.name))
        Rails.logger.info("Domain categories: #{domain.name} completed.")
        progressbar.increment
      end

      Headlines::Domain.connection.execute("DROP AGGREGATE IF EXISTS array_accum(anyarray)")
    end
  end
end
```
assistant