Skip to main content

OutputWriter

This class provides an interface to write back the outputs to the engine. It includes methods to put output accessors to the framework once a task completes.

Methods


Put()

@classmethod
def Put(
ctx: context.Context,
reader: [OutputReader](outputreader.md?sid=flyteplugins_go_tasks_pluginmachinery_io_outputreader)
) - > error

Once the task completes, use this method to indicate the output accessor to the framework

Parameters

NameTypeDescription
ctxcontext.ContextThe context for the operation, allowing for cancellation and deadlines.
reader[OutputReader](outputreader.md?sid=flyteplugins_go_tasks_pluginmachinery_io_outputreader)The OutputReader providing access to the task's output.

Returns

TypeDescription
errorAn error if the operation fails, otherwise nil.