🎯 Purpose
Process subscribers and send the outcome to Slack.
📥 Input fields
subscriber_ids: List[int]start_date: Optional[str]end_date: Optional[str]
🧩 Workflow steps
- Directory →
PROCESS_SUBSCRIBERS - LOCAL →
process_subscribers_slack_notification
📤 Result
Number of processed subscribers + Slack notification.
⚠️ Note
In the current implementation start_date and end_date are not passed
to PROCESS_SUBSCRIBERS (mapping uses owner).
📄 Code
apps/workflows/collections/process_subscribers.py