from flow_workflow.operations import base
from flow_workflow.operations.clone_inputs_future_net import CloneInputsNet


class ConnectorOperation(base.OperationBase):
    @property
    def name(self):
        return self._name


class InputConnector(ConnectorOperation):
    def __init__(self, name='input connector', *args, **kwargs):
        base.ConnectorOperation.__init__(self, *args, **kwargs)
        self._name = name

    def net(self, input_connections, output_properties, resources):
        return CloneInputsNet(name=self.name,
                operation_id=self.operation_id,
                input_connections=input_connections)


class OutputConnector(ConnectorOperation):
    def __init__(self, name='output connector', *args, **kwargs):
        base.ConnectorOperation.__init__(self, *args, **kwargs)
        self._name = name

    def net(self, input_connections, output_properties, resources):
        return CloneInputsNet(name=self.name,
                operation_id=self.parent.operation_id,
                input_connections=input_connections)

from flow_workflow.operations import base
from flow_workflow.operations.clone_inputs_future_net import CloneInputsNet


class ConnectorOperation(base.OperationBase):
    @property
    def name(self):
        return self._name


class InputConnector(ConnectorOperation):
    def __init__(self, name='input connector', *args, **kwargs):
        ConnectorOperation.__init__(self, *args, **kwargs)
        self._name = name

    def net(self, input_connections, output_properties, resources):
        return CloneInputsNet(name=self.name,
                operation_id=self.operation_id,
                input_connections=input_connections)


class OutputConnector(ConnectorOperation):
    def __init__(self, name='output connector', *args, **kwargs):
        ConnectorOperation.__init__(self, *args, **kwargs)
        self._name = name

    def net(self, input_connections, output_properties, resources):
        return CloneInputsNet(name=self.name,
                operation_id=self.parent.operation_id,
                input_connections=input_connections)

fix mistake in pylint cleanup