Module preprocessor.python

Functions

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

Classes

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