pgflow Flow that reconciles missing connector dispatches.
Scans connector-eligible events within a configurable time window (default: 24 hours) and creates dispatch records for any events that are missing dispatches for enabled connectors.
Mapping eligibility
For custom events, reconciliation gates on the connector mappings that are
enabled at reconciliation time (bounded by the lookback window). This is a
recovery mechanism: it backfills dispatches for events that are currently
mapped but never produced a dispatch. It therefore does not recover events
whose mapping was disabled or deleted after the event was recorded, and it may
create dispatches for in-window events that predate the mapping — both of which
are intentional consequences of using current mappings as the eligibility gate.
Usage
PgFlow.start_flow(GoodAnalytics.Flows.ConnectorReconciliation, %{
"workspace_id" => workspace_id
})Summary
Functions
Returns the cron expression, or nil if not scheduled.
Returns the static cron input map.
Returns the flow definition struct.
Pattern-matched handler function for each step.
Returns the flow slug.
Returns the raw step definitions.
Functions
Returns the cron expression, or nil if not scheduled.
Returns the static cron input map.
Returns the flow definition struct.
Pattern-matched handler function for each step.
Returns the flow slug.
Returns the raw step definitions.