Skip to content
This repository has been archived by the owner on Apr 26, 2024. It is now read-only.

On catchup, process each row with its own stream id #7286

Merged
merged 5 commits into from
Apr 20, 2020

Commits on Apr 16, 2020

  1. On catchup, process each row with its own stream id

    Other parts of the code (such as the StreamChangeCache) assume that there will
    not be multiple changes with the same stream id.
    richvdh committed Apr 16, 2020
    Configuration menu
    Copy the full SHA
    8f0870c View commit details
    Browse the repository at this point in the history
  2. Configuration menu
    Copy the full SHA
    c7c0fe3 View commit details
    Browse the repository at this point in the history

Commits on Apr 17, 2020

  1. Fix _batch_updates for py37

    turns out that as of py37/PEP424, if you let a StopIteration bubble out of a
    generator (as opposed to implicitly raising one by returning from said
    generator), it gets turned into a RuntimeError.
    
    Fix it by having `next` return None rather than raising StopIteration, and
    handling that.
    richvdh committed Apr 17, 2020
    Configuration menu
    Copy the full SHA
    f1709e2 View commit details
    Browse the repository at this point in the history
  2. Relax StreamChangeCache sanity-check

    It's pointless but valid to invalidate the same entity twice at the same stream
    id.
    richvdh committed Apr 17, 2020
    Configuration menu
    Copy the full SHA
    dc35b68 View commit details
    Browse the repository at this point in the history
  3. Remove the sanity check

    Argh. It turns out that if you introduce sanity-checks, you discover the places
    in which we are not adhering to them.
    richvdh committed Apr 17, 2020
    Configuration menu
    Copy the full SHA
    378d34e View commit details
    Browse the repository at this point in the history