Adam Shamlian
05/24/2021, 9:46 PMdef my_non_task_util_func(some_args):
return util_results
@task
def task_a(a_args):
return a_result
@task
def task_b(b_args):
return b_result
with Flow('test') as f:
util = my_non_task_util_func(some_args)
util_2 = my_non_task_util_func(some_other_args)
a = task_a(util, other_a_args)
b = task_b(util, util_2, a)
Should I be concerned about how Prefect treats this?
For further context, this util func is a factory for a collection of related prefect.tasks.core.constants.Constant
s. Thus far, it has been easier to return these from a vanilla func rather than a task that returns a collection of tasks.Amanda Wee
05/24/2021, 9:54 PMAdam Shamlian
05/24/2021, 9:57 PM