def METHOD_NAME(
    self,
    transform: Callable,
    dependencies: List[str] = None,
    preimported_modules: List[str] = None,
    runtime: str = _get_default_runtime(),
    communication_type: str = DEFAULT_ETL_COMM,
    timeout: str = DEFAULT_ETL_TIMEOUT,
    chunk_size: int = None,
    arg_type: str = "",