This commit is contained in:
Erik Johnston 2015-04-29 19:17:25 +01:00
parent 50f96f256f
commit 0ade2712d1

View file

@ -85,7 +85,7 @@ class StreamIdGenerator(object):
# ... persist event ...
"""
if not self._current_max:
self._compute_current_max(txn)
self._get_or_compute_current_max(txn)
with self._lock:
self._current_max += 1