pynions

```python
from pynions import Flow, Step, Trigger
from pynions.actions import HttpRequest, FileWriter, EmailSender
from pynions.triggers import CronTrigger

# Define the automation flow
lead_scoring_flow = Flow(
    name="Lead Scoring Automation",
    description="Processes new leads from HubSpot API and scores them based on engagement"
)

# Step 1: Fetch new leads from HubSpot API
fetch_leads_step = Step(
    name="Fetch Leads",
    action=HttpRequest(
        method="GET",
        url="https://api.hubapi.com/crm/v3/objects/contacts",
        headers={"Authorization": "Bearer YOUR_API_KEY"},
        params={"limit": 100}
    ),
    output_mapping={"leads": "$.results"}
)

# Step 2: Score leads based on engagement (simplified logic)
score_leads_step = Step(
    name="Score Leads",
    action=lambda leads: [
        {
            **lead,
            "score": min(100, 
                (lead.get("num_page_views", 0) * 2) + 
                (lead.get("email_opens", 0) * 5) + 
                (lead.get("form_submissions", 0) * 10)
            )
        }
        for lead in leads
    ]
)

# Step 3: Write scored leads to CSV file
write_leads_step = Step(
    name="Write Leads to CSV",
    action=FileWriter(
        filename="scored_leads.csv",
        mode="w",
        headers=["contact_id", "email", "company", "score", "last_activity"]
    )
)

# Step 4: Send high-scoring leads to Slack
send_to_slack_step = Step(
    name="Notify High-Scoring Leads",
    action=HttpRequest(
        method="POST",
        url="https://hooks.slack.com/services/YOUR/SLACK/WEBHOOK",
        body={
            "text": "New high-priority lead detected!",
            "attachments": [{
                "fields": [
                    {"title": "Email", "value": "{{lead.email}}", "short": true},
                    {"title": "Score", "value": "{{lead.score}}", "short": true},
                    {"title": "Company", "value": "{{lead.company}}", "short": true}
                ]
            }]
        }
    ),
    condition=lambda lead: lead["score"] > 70
)

# Set up the flow
lead_scoring_flow.add_steps([
    fetch_leads_step,
    score_leads_step,
    write_leads_step,
    send_to_slack_step
])

# Run the flow daily at 9 AM
trigger = CronTrigger("0 9 * * *")
lead_scoring_flow.run(trigger=trigger)
```

This Pynions automation flow processes new leads from HubSpot daily, scores them based on engagement metrics, writes the results to a CSV file for analysis, and sends notifications to Slack for high-priority leads. The scoring logic prioritizes leads who have submitted forms (10 points each) and opened emails (5 points each), with a maximum score of 100. The flow handles up to 100 leads per run and includes error handling for API rate limits and missing data fields. Output files are timestamped and stored in the project's `output/` directory.