from zk_locust import ZKLocust
from locust_extra.stats import register_extra_stats
from zk_metrics import register_zk_metrics

from zk_locust.task_sets import ZKConnectTaskSet

register_extra_stats()
register_zk_metrics()


class Connect(ZKLocust):
    task_set = ZKConnectTaskSet

    def __init__(self):
        # Unlike other locust instances, this one must not "autostart"
        # the ZK client.
        super(Connect, self).__init__(pseudo_root=None, autostart=False)

2370dce6ca8858f0728f156c0d05ffa48fa15550
<mask token>

<mask token>


class Connect(ZKLocust):
    <mask token>

    def __init__(self):
        super(Connect, self).__init__(pseudo_root=None, autostart=False)

<mask token>
register_extra_stats()
register_zk_metrics()


class Connect(ZKLocust):
    task_set = ZKConnectTaskSet

    def __init__(self):
        super(Connect, self).__init__(pseudo_root=None, autostart=False)

from zk_locust import ZKLocust
from locust_extra.stats import register_extra_stats
from zk_metrics import register_zk_metrics
from zk_locust.task_sets import ZKConnectTaskSet
register_extra_stats()
register_zk_metrics()


class Connect(ZKLocust):
    task_set = ZKConnectTaskSet

    def __init__(self):
        super(Connect, self).__init__(pseudo_root=None, autostart=False)

from zk_locust import ZKLocust
from locust_extra.stats import register_extra_stats
from zk_metrics import register_zk_metrics

from zk_locust.task_sets import ZKConnectTaskSet

register_extra_stats()
register_zk_metrics()


class Connect(ZKLocust):
    task_set = ZKConnectTaskSet

    def __init__(self):
        # Unlike other locust instances, this one must not "autostart"
        # the ZK client.
        super(Connect, self).__init__(pseudo_root=None, autostart=False)
