#6101 [BUG] FlyteRemote bug when trying to sync an execution of a workflow with of a dynamic subworkflow that contains a map_task
Issue created by
pingsutw
### Describe the bug
Create workflow and execute it
import flytekit as fl
@fl.task
def my_task(index: int):
print(index)
@fl.dynamic
def my_subworkflow(indices: list[int]):
fl.map_task(my_task)(index=indices)
@fl.workflow
def my_workflow():
indices = [1,2,3]
my_subworkflow(indices=indices)
Attempt to sync (and its children) it via FlyteRemote:
import flytekit as fl
remote = fl.FlyteRemote.for_endpoint(
endpoint="demo.hosted.unionai.cloud",
default_project="flytesnacks",
default_domain="development",
)
execution = remote.fetch_execution(name="arfcn55qj555x8v7pbc6")
synced = remote.sync(execution, sync_nodes=True)
### Expected behavior
should support to sync an execution of a workflow with of a dynamic subworkflow
### Additional context to reproduce
No response
### Screenshots
No response
### Are you sure this issue hasn't been raised already?
• Yes
### Have you read the Code of Conduct?
• Yes
flyteorg/flyte