# -*- coding:utf-8 -*- from configparser import ConfigParser from dw_base.datax.plugins.plugin import Plugin class Writer(Plugin): def __init__(self, base_dir: str, config_parser: ConfigParser, start_date: str = None, stop_date=None): super(Writer, self).__init__(base_dir, config_parser, start_date, stop_date) self.plugin_type = 'writer' def load_others(self): raise NotImplementedError('please implement this method in a specified writer.')