<filename>metaflow/plugins/debug_logger.py
import sys


class DebugEventLogger(object):
    TYPE = 'debugLogger'

    def log(self, msg):
        sys.stderr.write('event_logger: ' + str(msg)+'\n')

    def process_message(self, msg):
        # type: (Message) -> None
        self.log(msg.payload)

    def shutdown(self):
        pass

<filename>metaflow/plugins/debug_logger.py
import sys


class DebugEventLogger(object):
    TYPE = 'debugLogger'

    def log(self, msg):
        sys.stderr.write('event_logger: ' + str(msg)+'\n')

    def process_message(self, msg):
        # type: (Message) -> None
        self.log(msg.payload)

    def shutdown(self):
        pass

# type: (Message) -> None