Rupsha Chaudhuri
06/09/2022, 8:20 PM@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?Ketan (kumare3)
Rupsha Chaudhuri
06/09/2022, 9:15 PM@dynamic
def task_a(flag: bool):
res = ""
if flag:
result = task_b(some params)
res = result["field"]
return res
Ketan (kumare3)
Rupsha Chaudhuri
06/09/2022, 9:16 PMKetan (kumare3)
Rupsha Chaudhuri
06/09/2022, 9:16 PMKetan (kumare3)
Rupsha Chaudhuri
06/09/2022, 9:18 PMKetan (kumare3)
Rupsha Chaudhuri
06/09/2022, 9:22 PMKetan (kumare3)
Rupsha Chaudhuri
06/09/2022, 9:31 PMFlytekit does not support unary expressions of the form `if_(x) - where x is an input value or output of a previous node.
Ketan (kumare3)
Rupsha Chaudhuri
06/09/2022, 9:41 PMKetan (kumare3)
Rupsha Chaudhuri
06/09/2022, 9:42 PMKetan (kumare3)
Rupsha Chaudhuri
06/09/2022, 11:05 PM