Anh Nguyen
09/23/2021, 1:53 AMKevin Kho
09/23/2021, 2:38 AMcls = MyClass()
@task
def task_A():
cls.do_something()
return
Anh Nguyen
09/23/2021, 1:20 PMKevin Kho
09/23/2021, 2:29 PMcloudpickle
to send stuff to the workers. So the limitations here are that you need to use LocalExecutor or LocalDaskExecutor (with threads) and then:
cls = MyClass()
@task
def task_A():
cls.do_something()
return
with Flow(...) as flow:
task_A.map([1,2,3])
but this requires your flow to be stored as a script because the default behavior is to serialize your Flow and these connections cant be serialized