datax-admin/app/core/datax/base.py

from app.schemas.datax_json import DataXJsonParam, RWDataSource


class ReaderBase:
    def __init__(self, ds: RWDataSource):
        self.ds = ds

    def build(self, param: DataXJsonParam):
        pass

class WriterBase:
    def __init__(self, ds: RWDataSource):
        self.ds = ds
    def build(self):
        pass