Module preprocessor.python

Functions

def debug(msg)
def eprint(*args, **kwargs)
def postprocess(data: Union[pandas.core.frame.DataFrame, dict], venv: str, script: str, report_ctx: dict) -> pandas.core.frame.DataFrame
def postprocess_chunked(data_iter: Iterator[Union[pandas.core.frame.DataFrame, dict]], venv: str, script: str, report_ctx: dict) -> Iterator[pandas.core.frame.DataFrame]
def transform(data: Union[pandas.core.frame.DataFrame, dict], venv: str, script: str) -> pandas.core.frame.DataFrame
def transform_chunked(data_iter: Iterator[Union[pandas.core.frame.DataFrame, dict]], venv: str, script: str) -> Iterator[pandas.core.frame.DataFrame]

Classes

class TransformIterator (data_itr: Iterator[Union[pandas.core.frame.DataFrame, dict]], venv: str, script: str, is_postprocess=False, report_ctx=None)