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

from app.models.job_jdbc_datasource import JobJdbcDatasource
from app.schemas.datax_json import DataXJsonParam


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

    def build(self, param: DataXJsonParam):
        pass

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