Hi folks... I have a

@dynamic

task that calls a

@task

task that's expected to return a dict. Instead I'm getting a

flytekit.core.promise.Promise

object back. I also don't see any of the logs from that task.. nor do I see the called task executing on the console. What's weird is that the same called task works as expected when invoked from other tasks in the same workflow. Can someone help me understand why a task would not execute and return a Promise instead?

Can you share the snippet

this is what I have... more or less

@dynamic
def task_a(flag: bool):
    res = ""
    if flag:
        result = task_b(some params)
        res = result["field"]
    return res

You cannot access result

so how do I structure this?

Want to jump on a call

Is dynamic the wrong construct?

Depends

Sure... let me know when to hop on

Read this part https://docs.flyte.org/projects/cookbook/en/stable/auto/core/control_flow/dynamics.html

got it.. let me try this with conditions

Got it

Not sure about the syntax when using create_node.. but let me try it first

You cannot do truth value directly

ah

@workflow def bool_input_wf(b: bool) -> int: return conditional("test").if_(b.is_true()).then(success()).else_().then(failed())

alright.. let me try this

Ya but that is weird what do you want to do in then

I got it to work.. so not a problem.. just found it a bit strange, that's all 🙂