smallpond.execution.task.Task
=============================

.. currentmodule:: smallpond.execution.task

.. autoclass:: Task

   
   .. automethod:: __init__

   
   .. rubric:: Methods

   .. autosummary::
   
      ~Task.__init__
      ~Task.add_elapsed_time
      ~Task.adjust_row_group_size
      ~Task.clean_complex_attrs
      ~Task.clean_output
      ~Task.cleanup
      ~Task.compute_avg_row_size
      ~Task.dump
      ~Task.exec
      ~Task.finalize
      ~Task.get_partition_info
      ~Task.initialize
      ~Task.inject_fault
      ~Task.merge_metrics
      ~Task.oom
      ~Task.parquet_kv_metadata_bytes
      ~Task.parquet_kv_metadata_str
      ~Task.random_float
      ~Task.random_uint32
      ~Task.run
      ~Task.run_on_ray
      ~Task.set_memory_limit
   
   

   
   
   .. rubric:: Attributes

   .. autosummary::
   
      ~Task.ctx
      ~Task.id
      ~Task.node_id
      ~Task.sched_epoch
      ~Task.output_name
      ~Task.output_root
      ~Task.dataset
      ~Task.input_deps
      ~Task.output_deps
      ~Task.perf_metrics
      ~Task.perf_profile
      ~Task.runtime_state
      ~Task.input_datasets
      ~Task.allow_speculative_exec
      ~Task.any_input_empty
      ~Task.cpu_limit
      ~Task.default_output_name
      ~Task.elapsed_time
      ~Task.exception
      ~Task.exec_cq
      ~Task.exec_id
      ~Task.exec_on_scheduler
      ~Task.fail_count
      ~Task.final_output_abspath
      ~Task.finish_time
      ~Task.gpu_limit
      ~Task.key
      ~Task.local_gpu
      ~Task.local_gpu_ranks
      ~Task.local_rank
      ~Task.location
      ~Task.memory_limit
      ~Task.numa_node
      ~Task.numpy_random_gen
      ~Task.output
      ~Task.output_dirname
      ~Task.output_filename
      ~Task.partition_dims
      ~Task.partition_infos
      ~Task.partition_infos_as_dict
      ~Task.python_random_gen
      ~Task.random_seed_bytes
      ~Task.ray_dataset_path
      ~Task.ray_marker_path
      ~Task.retry_count
      ~Task.runtime_id
      ~Task.runtime_output_abspath
      ~Task.self_contained_output
      ~Task.skip_when_any_input_empty
      ~Task.staging_root
      ~Task.start_time
      ~Task.status
      ~Task.temp_abspath
      ~Task.temp_output
      ~Task.uniform_failure_prob