loud-barista-15046
11/04/2024, 10:06 PMfreezing-airport-6809
red-holiday-95178
11/05/2024, 12:08 AMflytekit.task
object if you want to be more granular and wrap the underlying task function itself, such as:
def wrapper(func):
@functools.wraps(func)
def special_logger(*args): ...
function_task = flytekit.task(
_task_function=special_logger,
...
)
return function_task
The link provided by @freezing-airport-6809 provides a probably simpler and effective solution for most use cases.freezing-airport-6809
loud-barista-15046
11/05/2024, 10:16 AM