Hey, is this supposed to work? It works for me on the cluster but not locally (ie. just running it with python), in tk_agg the list items are promises instead of Something instances (so x.n fails)

from flytekit import dynamic, task, workflow

class Something:
    n: int

@task
def tk_inner() -> Something:
    s = Something()
    s.n = 3
    return s

@task
def tk_agg(s: list[Something]) -> int:
    return sum(x.n for x in s)

@dynamic
def tk_outer() -> int:
    s = [tk_inner() for _ in range(5)]
    return tk_agg(s=s)

@workflow
def wf_outer() -> int:
    return tk_outer()

assert wf_outer() == sum(range(5))

It is supposed to work. This seems like a flytekit local executor bug. Cc @Yee : @Kevin Su can either of you take a look

What’s the Something? Is it something that gets pickled?

all the code is there including the class Something, should be able to just run that script. the error was that it tried to call .json() which didn't exist iirc (but could be wrong), but I'm not at my pc atm to check