# -*- coding: utf-8 -*-
from pipelines.stage import Stage

__author__ = 'vdv'


class Break(Stage):
    def __init__(self, name, config, bus, filter, service_resolver):
        Stage.__init__(self, name=name, config=config, bus=bus, filter=filter, service_resolver=service_resolver)

    def execute(self):
        self.bus.dispose()

        return True

    @property
    def is_interfere(self):
        return False
af8bdc54729323dc1e6782ef72e3077a546b7f7d
<mask token>


class Break(Stage):
    <mask token>

    def execute(self):
        self.bus.dispose()
        return True

    @property
    def is_interfere(self):
        return False

<mask token>


class Break(Stage):

    def __init__(self, name, config, bus, filter, service_resolver):
        Stage.__init__(self, name=name, config=config, bus=bus, filter=
            filter, service_resolver=service_resolver)

    def execute(self):
        self.bus.dispose()
        return True

    @property
    def is_interfere(self):
        return False

<mask token>
__author__ = 'vdv'


class Break(Stage):

    def __init__(self, name, config, bus, filter, service_resolver):
        Stage.__init__(self, name=name, config=config, bus=bus, filter=
            filter, service_resolver=service_resolver)

    def execute(self):
        self.bus.dispose()
        return True

    @property
    def is_interfere(self):
        return False

from pipelines.stage import Stage
__author__ = 'vdv'


class Break(Stage):

    def __init__(self, name, config, bus, filter, service_resolver):
        Stage.__init__(self, name=name, config=config, bus=bus, filter=
            filter, service_resolver=service_resolver)

    def execute(self):
        self.bus.dispose()
        return True

    @property
    def is_interfere(self):
        return False

# -*- coding: utf-8 -*-
from pipelines.stage import Stage

__author__ = 'vdv'


class Break(Stage):
    def __init__(self, name, config, bus, filter, service_resolver):
        Stage.__init__(self, name=name, config=config, bus=bus, filter=filter, service_resolver=service_resolver)

    def execute(self):
        self.bus.dispose()

        return True

    @property
    def is_interfere(self):
        return False