

@implementation
def test_merge(self):
    aggregator = self.aggregator_class()
    middle_index = (len(self.first_activities_group) // 2)
    first = aggregator.aggregate(self.first_activities_group[:middle_index])
    (new, changed, deleted) = aggregator.merge(first, self.first_activities_group[middle_index:])
    self.assertEqual(len(new), 0)
    self.assertEqual(len(deleted), 0)
    (old, updated) = changed[0]
    self.assertEqual(old.activities, self.first_activities_group[:aggregator])
    self.assertEqual(updated.activities, self.first_activities_group)

dataset/ETHPy150Open tschellenbach/Stream-Framework/stream_framework/tests/aggregators/__init__.py BaseAggregatorTest.test_merge/VarMisuse@120/148 `middle_index`->`aggregator`