legate.core.ParallelPolicy

class legate.core.ParallelPolicy(

StreamingMode streaming_mode: StreamingMode = StreamingMode.OFF,

*,

uint32_t overdecompose_factor: uint32_t = 1,

partitioning_threshold: dict[TaskTarget,

uint64_t] | tuple[TaskTarget,

uint64_t] | None=None,

)

__init__()

Parameters:

• streaming_mode (StreamingMode) – Enum that enables streaming in STRICT or RELAXED mode. Default = OFF

• overdecompose_factor (int) – The over-decomposition factor. Default = 1

• partitioning_threshold (dict[TaskTarget, uint64_t]) –

  tuple[TaskTarget, uint64_t]

  Partitioning thresholds for various processor types specified as either a tuple or dictionary of [TaskTarget, int]. Default thresholds are picked based on Legate Runtime’s configuration controlled by the environment variable LEGATE_CONFIG. Default = None

Raises:

ValueError – If any of the following happen: 1) overdecompose_factor < 1 2) partitioning_threshold is not a tuple or dict 3) partitioning_threshold is not a tuple of [TaskTarget, uint64_t]

Attributes

overdecompose_factor	uint32_t
streaming	bool
streaming_mode	StreamingMode

Methods

__eq__(value, /)	Return self==value.
__ge__(value, /)	Return self>=value.
__gt__(value, /)	Return self>value.
__le__(value, /)	Return self<=value.
__lt__(value, /)	Return self<value.
__ne__(value, /)	Return self!=value.
partitioning_threshold(self, TaskTarget target)	Get the value of partitioning_threshold for a processor type.
set_partitioning_threshold(self, ...)	Set the partitioning_threshold for a processor type.