def __init__()

in smallpond/execution/task.py [0:0]

• 22 lines of code
• 1 McCabe index (conditional complexity)

    def __init__(
        self,
        ctx: RuntimeContext,
        input_deps: List[Task],
        partition_infos: List[PartitionInfo],
        npartitions: int,
        dimension: str,
        hash_columns: List[str],
        data_partition_column: str,
        random_shuffle: bool = False,
        shuffle_only: bool = False,
        drop_partition_column=False,
        use_parquet_writer=False,
        hive_partitioning=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,
        memory_limit: int = None,