Workflow AutomationIf a human does it twice,we automate it.

@workflow(trigger="webhook", retry=3)
async def process_new_lead(payload: WebhookPayload):
    # Validate and normalize incoming lead data
    lead = validate_lead(payload)

    # Create or update CRM record in GoHighLevel
    ghl_contact = await ghl.upsert_contact(
        email=lead.email,
        name=lead.name,
        tags=["new-lead", lead.source],
        pipeline_stage="qualification"
    )

    # Provision project in Monday.com if qualified
    if lead.score >= QUALIFICATION_THRESHOLD:
        await monday.create_item(
            board_id=ONBOARDING_BOARD,
            name=f"Onboard: {lead.company}",
            columns={"status": "New", "contact": ghl_contact.id}
        )

    # Trigger welcome sequence
    await ghl.start_workflow(
        contact_id=ghl_contact.id,
        workflow="welcome-sequence-v2"
    )

    await slack.notify(f"New lead: {lead.name} ({lead.company})")