cubed.TaskEndEvent

cubed.TaskEndEvent#

class cubed.TaskEndEvent(name, num_tasks=1, result=None, task_create_tstamp=None, function_start_tstamp=None, function_end_tstamp=None, task_result_tstamp=None, peak_measured_mem_start=None, peak_measured_mem_end=None)#

Callback information about a completed task (or tasks).

__init__(name, num_tasks=1, result=None, task_create_tstamp=None, function_start_tstamp=None, function_end_tstamp=None, task_result_tstamp=None, peak_measured_mem_start=None, peak_measured_mem_end=None)#

Methods

__init__(name[, num_tasks, result, ...])

Attributes

function_end_tstamp

Timestamp of when the function finished executing on the remote worker.

function_start_tstamp

Timestamp of when the function started executing on the remote worker.

num_tasks

Number of tasks that this event applies to (default 1).

peak_measured_mem_end

Peak memory usage measured on the remote worker after the function finishes executing.

peak_measured_mem_start

Peak memory usage measured on the remote worker before the function starts executing.

result

Return value of the task.

task_create_tstamp

Timestamp of when the task was created by the client.

task_result_tstamp

Timestamp of when the result of the task was received by the client.

name

Name of the operation that the task is for.