Skip to content

Commit

Permalink
Remove redundant jump_to in _move_stream_time #17
Browse files Browse the repository at this point in the history
The first thing shard.seek_to does is jump_to("trim_horizon"),
so there's no need to do an extra jump within the shard walking
of _move_stream_time
  • Loading branch information
numberoverzero committed Oct 17, 2016
1 parent 72428f7 commit 0a68abb
Showing 1 changed file with 0 additions and 2 deletions.
2 changes: 0 additions & 2 deletions bloop/stream/coordinator.py
Original file line number Diff line number Diff line change
Expand Up @@ -225,8 +225,6 @@ def _move_stream_time(coordinator: Coordinator, time: arrow.Arrow) -> None:
elif shard.exhausted:
coordinator.remove_shard(shard)
shard_trees.extend(shard.children)
for child in shard.children:
child.jump_to(iterator_type="trim_horizon")

# Nothing to do if the shard didn't seek to the time AND isn't exhausted,
# since that means it's open and the target could still appear in its future.
Expand Down

0 comments on commit 0a68abb

Please sign in to comment.