funcx.sdk.utils.batch.Batch

class funcx.sdk.utils.batch.Batch(task_group_id=None)

Utility class for creating batch submission in funcX

__init__(task_group_id=None)
Parameters:task_group_id (str) – UUID indicating the task group that this batch belongs to

Methods

__init__([task_group_id])
param task_group_id:
 UUID indicating the task group that this batch belongs to
add(*args[, endpoint_id, function_id]) Add an function invocation to a batch submission
prepare() Prepare the payloads to be post to web service in a batch