Your Creative & Digital
Growth Partner

// 1. Data Ingestion & Schema Extraction
import { DataPipeline } from '@wemagnifai/core';

const pipe = new DataPipeline({
    source: 'leads_lake',
    stream: true
});

pipe.on('data', async (rawLead) => {
    const parsed = await pipe.score(rawLead);
    if (parsed.intentScore > 0.85) {
        await pipe.routeTo('nurture_swarm', parsed);
    }
});