Write Workflows

import { definePlay } from 'deepline';

type Lead = {
  lead_id: string;
  linkedin_url: string;
  company_domain: string;
};

export default definePlay('lead-email-waterfall', async (ctx, input: { leads: Lead[] }) => {
  const rows = await ctx
    .dataset('lead_email', input.leads)
    .withColumn('email', async (lead, rowCtx) => {
      const result = await rowCtx.tools.execute({
        id: 'person_email',
        tool: 'test_rate_limit',
        input: {
          key: lead.linkedin_url,
        },
        description: 'Find a verified work email for this lead.',
      });
      return result.status === 'SUCCESS' ? `lead@${lead.company_domain}` : null;
    })
    .run({ key: 'lead_id', description: 'Find one email per lead.' });

  return { rows };
});

import { definePlay } from 'deepline';

type Account = {
  domain: string;
  seniority: 'VP' | 'Director';
};

export default definePlay('route-qualified-accounts', async (ctx, input: { accounts: Account[] }) => {
  const rows = await ctx
    .dataset('qualified_accounts', input.accounts)
    .withColumn('next_step', async (account, rowCtx) => {
      if (account.seniority === 'VP') {
        return await rowCtx.tools.execute({
          id: 'vp_research',
          tool: 'test_rate_limit',
          input: { key: account.domain },
          description: 'Research this enterprise account.',
        });
      }

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

  return { rows };
});

import { definePlay } from 'deepline';

type SearchInput = {
  query: string;
  owner_email: string;
};

type Account = {
  domain: string;
  owner_email: string;
};

export default definePlay('weekly-new-accounts', async (ctx, input: SearchInput) => {
  const companies: Account[] = [
    { domain: 'example.com', owner_email: input.owner_email },
    { domain: 'acme.com', owner_email: input.owner_email },
  ];

  const enriched = await ctx.dataset('new_accounts', companies)
    .withColumn('signals', (account, rowCtx) =>
      rowCtx.tools.execute({
        id: 'company_research',
        tool: 'test_rate_limit',
        input: { key: `${input.query}:${account.domain}` },
        description: 'Research the new account.',
      }),
    )
    .withColumn('salesforce', (account, rowCtx) =>
      rowCtx.tools.execute({
        id: 'create_salesforce_task',
        tool: 'test_rate_limit',
        input: {
          key: `${account.domain}:${account.owner_email}`,
        },
        description: 'Create the owner follow-up task.',
      }),
    )
    .run({ key: 'domain', description: 'Research new accounts and create Salesforce tasks.' });

  return { rows: enriched };
});

import { definePlay } from 'deepline';

type Account = {
  domain: string;
};

export default definePlay('nightly-refresh', async (ctx, input: { accounts: Account[] }) => {
  const rows = await ctx
    .dataset('accounts', input.accounts)
    .withColumn('company_signal', (account, rowCtx) =>
      rowCtx.tools.execute({
        id: 'company_signal',
        tool: 'test_rate_limit',
        input: { key: account.domain },
        description: 'Refresh one account signal.',
      }),
    )
    .run({ key: 'domain' });

  return { rows };
}, {
  billing: { maxCreditsPerRun: 25 },
});