Source code for cluster.preprocess.pre_node

from cluster.common.common_node import WorkFlowCommonNode

[docs]class PreProcessNode(WorkFlowCommonNode):
    """

    """

[docs]    def run(self, conf_data):
        pass

    def _init_node_parm(self):
        pass

    def _set_progress_state(self):
        pass

[docs]    def load_data(self, node_id, parm = 'all'):
        pass