Module preprocessor.python

Functions

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

Classes

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