@task
def task1():
    print("1")

@task
def task2():
    print("2")

@task
def task3():
    print("3") 

@dynamic
def dynamic_wf() -> str:
    node_1 = create_node(
        task1
    )       
    node_2 = create_node(
        task2
    )
    node_3 = create_node(
        task3
    )

    node_3 >> node_2
    node_1 >> node_2

    return "Done"

@workflow
def wf2() -> str:
    return dynamic_wf()

pyflyte run file.py wf2

create_node

@dynamic