# Path: pypipeline/core/Destination.py
# class Destination:
#     def __init__(self, plumber, params):
#         self.plumber = plumber
#         self.params = params
# 
#     def process(self, exchange):
#         raise NotImplementedError("Subclass of destination needs to implement process method")


from pypipeline.core.Destination import Destination


class Log(Destination):
    def __init__(self, plumber, params):
        super().__init__(plumber, params)

# Path: pypipeline/core/Destination.py
# class Destination:
#     def __init__(self, plumber, params):
#         self.plumber = plumber
#         self.params = params
# 
#     def process(self, exchange):
#         raise NotImplementedError("Subclass of destination needs to implement process method")


# Path: pypipeline/components/destination/Log.py
from pypipeline.core.Destination import Destination



class Log(Destination):
    def __init__(self, plumber, params):
        super().__init__(plumber, params)

        self.name = params["name"]