Operational Workspace

Data Pipeline

3 Directors, 6 Managers, 30 Workers — cascading intelligence across 8 data domains

Directors

Managers

Workers

Domains

Breweries

Tiers

Run Commands

$ npm run agents:hierarchy # Full 3-tier cascade

$ npm run agents:hierarchy:dry # Dry run (print DAG only)

$ npm run agents:hierarchy:collect # Collection director only

# Legacy flat runner still works:

$ npm run agents:run # Old 8-agent flat swarm

Collection Director

Orchestrates raw data gathering. Prioritizes stale breweries and manages API budgets.

Data Collection Manager

collection

collectorWeb Scraper

Website existence, SSL, languages, mobile, online shop, SEO

collectorSocial Media Checker

Instagram, Twitter/X, Facebook, YouTube, LINE presence

collectorGoogle Maps Lookup

Ratings, review counts, listing status from Google Maps

collectorUntappd Fetcher

Beer ratings, rating counts, beer counts from Untappd

analyzerSEO Deep Audit

Core Web Vitals, structured data, backlink estimation

Depends on: Web Scraper

analyzerSocial Engagement

Posting frequency, engagement rates, platform depth

Depends on: Social Media

Intelligence Director

Orchestrates analysis and enrichment across all domains after collection completes.

Digital Presence Manager

digital-presence

analyzerDigital Presence Analyzer

Composite score: website (0-30), social (0-30), SEO (0-20), reviews (0-20)

Depends on: Web Scraper, Social Media, Google Maps, Untappd

analyzerSEO Deep Audit

Deep SEO with Core Web Vitals simulation

Depends on: Web Scraper

analyzerSocial Engagement

Engagement depth analysis

Depends on: Social Media

Product Intelligence Manager

flavor / ingredients / water / production

collectorFlavor Scraper

Flavor descriptors, fingerprints, IBU/ABV ranges from styles

analyzerFlavor Profiler

Signature style classification (hop-forward, malt-driven, etc.)

Depends on: Flavor Scraper

collectorIngredient Scraper

Hop varieties, malt types, specialty local ingredients

analyzerLocal Sourcing Detector

Identifies local ingredient sources per prefecture

Depends on: Ingredient Scraper

collectorWater Source Mapper

Maps water source, hardness, pH by region

analyzerWater Profile Analyzer

Water-to-style impact analysis

Depends on: Water Source Mapper

collectorBrewing Method Scraper

Techniques, fermentation type, barrel aging, equipment

collectorEquipment Detector

Equipment origin, brew length, vessel count

analyzerSeasonal Cycle Mapper

Maps seasonal beer releases by region

Depends on: Brewing Method Scraper

Business Intelligence Manager

business / corporate / distribution

enricherCorporate Registry

NTA houjin-bangou lookup with prefecture codes

analyzerBusiness Practice Analyzer

Distribution, exports, certifications, hospitality

Depends on: Web Scraper, Corporate Registry

collectorRetail Channel Scanner

Konbini, supermarket, craft shops, department stores

collectorOn-Premise Mapper

Bars, izakaya, restaurants, hotels, venue count

collectorE-Commerce Detector

Rakuten, Amazon JP, furusato nozei, own site

analyzerExport Channel Analyzer

Distributors, export share, country breakdown

Depends on: Retail Channel Scanner

Brand Intelligence Manager

branding / awards

collectorBranding Scraper

Logo analysis, label style, brand positioning

collectorEvents Collector

Festivals, taproom events, popups

analyzerCollaboration Mapper

Brewery-to-brewery and cross-industry collabs

Depends on: Events Collector

enricherAwards Collector

5 major competitions with quality-weighted probability

People Intelligence Manager

staff

collectorStaff Scraper

Headcount, head brewer, foreign staff

analyzerDemographics Estimator

Gender split, brewer background, certifications

Depends on: Staff Scraper

Quality Director

Runs last. Cross-references all domains for inconsistencies and produces per-brewery quality scores.

Direct cross-domain validation — no managed workers