§5 Real-time schedule-driven streams (queries on our own data)
The pull side — queries we run on a schedule
Queries we run on our own stored data on a schedule, surfacing tasks from patterns or absences. Where event-driven streams (§4) capture something happened, schedule-driven streams (§5) capture something hasn't happened (or has reached a threshold quietly).
| Query | Cadence | Tasks it spawns | Origin bucket |
|---|---|---|---|
| Trips departing in N days | Daily | Pre-arrival checklist | Trip lifecycle |
| Clients with no message > N hours | Hourly | Follow-up draft | Internal ops |
| Tasks past due-date | 15-min | Escalate to TA / ops manager | Internal ops |
| Saved searches: hotel rate ≤ threshold | Hourly | "Book now" alert | World-driven |
| Saved searches: award space appears | 15-min | "Book award" alert | World-driven |
| Visa / passport expiring < 6 mo | Daily | Renewal reminder | World-driven |
| Birthday / anniversary in N days | Daily | Personalised outreach | Relationship |
| Loyalty milestone (3rd trip, 5-year mark, etc.) | Daily | Gesture / outreach | Relationship |
| SLA timers approaching breach | Continuous | Escalate, prioritise | Internal ops |
| Trips stuck in same stage > N days | Daily | "Why is this stuck?" diagnostic | Internal ops |
| Open tasks per ops/TA — workload check | Hourly | Reassign if overloaded | Internal ops |
Why schedule-driven streams matter
Most of these aren't covered by message-driven AI; they need the system to actively look for situations that warrant a task. This is where we catch the "the dog that didn't bark" failure modes — clients we forgot about, trips that quietly stalled, deals we missed.
What's open about schedule-driven streams (see §8)
Poll cadence per query, scope boundary versus an Alerts feature, and how we surface the difference between "a task" (something to do) and "an alert" (something to know).
2 READ Stream Flow
READ FLOW
Scheduler
Timer
15min / hourly / daily
15min / hourly / daily
AI capability
Run query
Poll data store
For each match
Multi-instance loop
Propose task
Generate proposal
Confidence?
Outcome
Auto-create
Human review
Gated
Reviewed (created or skipped)
BPMN Notation
Timer start event
End event
User task (human)
Service task (automated)
Exclusive gateway (XOR)