Function timeCursorOrderBy

apps/sim/lib/data-drains/sources/cursor.ts:54–56

(timestampCol: PgColumn, idCol: PgColumn)

 * millisecond bucketing so cursor advancement never skips rows.
 */
export function timeCursorOrderBy(timestampCol: PgColumn, idCol: PgColumn): [SQL, SQL] {
  return [sql`date_trunc('milliseconds', ${timestampCol}) asc`, sql`${idCol} asc`]
}

/**
 * Excludes rows newer than a short stability window. Timestamp cursors assume