Is there a way to assign a task result handler from an imported task? Like the equivalent of this:
Copy code
from prefect import task
from prefect.engine.result.local_result import LocalResult
from my_prefect_tasks import imported_task
@task(result=LocalResult())
def assigned_result_task(x):
return x
imported_task.result_handler = LocalResult()
Bring your towel and join one of the fastest growing data communities. Welcome to our second-generation open source orchestration platform, a completely rethought approach to dataflow automation.