Deepline SDK

deepline plays describe prebuilt/person-linkedin-to-email --json

deepline plays run prebuilt/person-linkedin-to-email \
  --input '{"linkedin_url":"https://www.linkedin.com/in/real-person/"}' \
  --watch

head -n 4 leads.csv > /tmp/leads-pilot.csv

deepline plays run lead-email-waterfall.play.ts \
  --csv /tmp/leads-pilot.csv \
  --watch

deepline runs export <run-id> --out /tmp/leads-pilot-enriched.csv

import { definePlay } from 'deepline';

type Lead = {
  lead_id: string;
  seniority: 'VP' | 'Director';
  company_domain: string;
};

export default definePlay(
  'route-leads-by-seniority',
  async (ctx, input: { leads: Lead[] }) => {
    const rows = await ctx
      .dataset('routed_leads', input.leads)
      .withColumn('research', async (lead, rowCtx) => {
        if (lead.seniority === 'VP') {
          return await rowCtx.tools.execute({
            id: 'vp_research',
            tool: 'test_rate_limit',
            input: { key: lead.company_domain },
            description: 'Research this enterprise lead.',
          });
        }

        return await rowCtx.tools.execute({
          id: 'director_research',
          tool: 'test_rate_limit',
          input: { key: lead.company_domain },
          description: 'Research this midmarket lead.',
        });
      })
      .run({
        key: 'lead_id',
        description: 'Route each lead to the right research workflow.',
      });

    return { rows };
  },
);

deepline plays run weekly-new-accounts.play.ts \
  --input '{"query":"B2B SaaS companies hiring RevOps"}' \
  --watch

deepline runs export <run-id> --out output/new-accounts.csv