limit batch size on announcer test so it covers batching logic

This commit is contained in:
Victor Shyba 2019-05-07 01:32:55 -03:00
parent c6a3c05a0c
commit 84b471d486

View file

@ -85,7 +85,7 @@ class TestBlobAnnouncer(AsyncioTestCase):
) )
to_announce = await self.storage.get_blobs_to_announce() to_announce = await self.storage.get_blobs_to_announce()
self.assertEqual(2, len(to_announce)) self.assertEqual(2, len(to_announce))
self.blob_announcer.start() self.blob_announcer.start(batch_size=1) # so it covers batching logic
await self.advance(61.0) await self.advance(61.0)
to_announce = await self.storage.get_blobs_to_announce() to_announce = await self.storage.get_blobs_to_announce()
self.assertEqual(0, len(to_announce)) self.assertEqual(0, len(to_announce))