from base_test_ci import BaseTest
import config
import os
import time
from google.cloud import pubsub_v1
import unittest


class Test1(BaseTest):

    def test_sendId(self):
        messages = self.run_phase(nodes=1, bootstrap='false')
        self.assertLess(15, len(messages[0]))


if __name__ == '__main__':
    unittest.main()

62d2ea87716b824e532679b8a9b972351b731754
<mask token>

<mask token>


class Test1(BaseTest):

    def test_sendId(self):
        messages = self.run_phase(nodes=1, bootstrap='false')
        self.assertLess(15, len(messages[0]))


<mask token>

<mask token>


class Test1(BaseTest):

    def test_sendId(self):
        messages = self.run_phase(nodes=1, bootstrap='false')
        self.assertLess(15, len(messages[0]))


if __name__ == '__main__':
    unittest.main()

from base_test_ci import BaseTest
import config
import os
import time
from google.cloud import pubsub_v1
import unittest


class Test1(BaseTest):

    def test_sendId(self):
        messages = self.run_phase(nodes=1, bootstrap='false')
        self.assertLess(15, len(messages[0]))


if __name__ == '__main__':
    unittest.main()
