legate.core.ManualTask#

class legate.core.ManualTask#
__init__(*args, **kwargs)#

Attributes

exception_types

tuple[type]

raw_handle

uintptr_t

Methods

add_cal_communicator(self)

Adds a CAL communicator to the task

add_communicator(self, str name)

Add a communicator to the task

add_cpu_communicator(self)

Adds a CPU communicator to the task

add_input(self, arg[, projection])

Adds an input to the task.

add_nccl_communicator(self)

Adds a NCCL communicator to the task

add_output(self, arg[, projection])

Adds an output to the task.

add_reduction(self, arg, int32_t redop[, ...])

add_scalar_arg(self, value[, dtype])

Adds a by-value argument to the task

execute(self)

Submits the operation to the runtime.

provenance(self)

Returns the provenance of this task.

set_concurrent(self, bool concurrent)

Set whether a task requires a concurrent task launch.

set_side_effect(self, bool has_side_effect)

Set whether a task has side effects.

throws_exception(self, type exception_type)

Set which exception is thrown by the task.