flytekit.extend.ShimTaskExecutor

class flytekit.extend.ShimTaskExecutor(*args, **kwargs)

Methods

execute_from_model(tt, **kwargs)

This function must be overridden and is where all the business logic for running a task should live. Keep in mind that you’re only working with the TaskTemplate. You won’t have access to any information in the task that wasn’t serialized into the template.

Parameters:

• tt (TaskTemplate) – This is the template, the serialized form of the task.

• kwargs – These are the Python native input values to the task.

Returns:

Python native output values from the task.

Return type:

Any

find_lhs()

Return type:

str

Attributes

instantiated_in

lhs

location