in smallpond/execution/task.py [0:0]
def __init__(
self,
ctx: RuntimeContext,
input_deps: List[Task],
partition_infos: List[PartitionInfo],
sql_queries: List[str],
udfs: List[UDFContext] = None,
per_thread_output=True,
materialize_output=True,
materialize_in_memory=False,
batched_processing=False,
enable_temp_directory=False,
parquet_row_group_size: int = DEFAULT_ROW_GROUP_SIZE,
parquet_dictionary_encoding=False,
parquet_compression="ZSTD",
parquet_compression_level=3,
output_name: str = None,
output_path: str = None,
cpu_limit: int = None,
gpu_limit: float = None,
memory_limit: int = None,
cpu_overcommit_ratio: float = 1.0,
memory_overcommit_ratio: float = 0.9,