in smallpond/execution/task.py [0:0]
def __init__(
self,
job_id: JobId,
job_time: datetime,
data_root: str,
*,
num_executors: int = 1,
random_seed: int = None,
env_overrides: Dict[str, str] = None,
bind_numa_node=False,
enforce_memory_limit=False,
max_usable_cpu_count: int = 1024,
max_usable_gpu_count: int = 1024,
max_usable_memory_size: int = 16 * TB,
secs_wq_poll_interval: float = 0.5,
secs_executor_probe_interval: float = 30,
max_num_missed_probes: int = 6,
fault_inject_prob=0.0,
enable_profiling=False,
enable_diagnostic_metrics=False,
remove_empty_parquet=False,
skip_task_with_empty_input=False,
shared_log_root: Optional[str] = None,
console_log_level="INFO",
file_log_level="DEBUG",
disable_log_rotation=False,
output_path: Optional[str] = None,