def test_wf1_with_map():

    @task
    def t1(a: int) -> typing.NamedTuple('OutputsBC', t1_int_output=int, c=str):
        a = (a + 2)
        return (a, ('world-' + str(a)))

    @task
    def t2(a: typing.List[int], b: typing.List[str]) -> (int, str):
        ra = 0
        for x in a:
            ra += x
        rb = ''
        for x in b:
            rb += x
        return (ra, rb)

    @workflow
    def my_wf(a: typing.List[int]) -> (int, str):
        (x, y) = maptask(t1, metadata=TaskMetadata(retries=1))(a=a)
        return t2(a=x, b=y)
    x = my_wf(a=[5, 6])
    assert (x == (15, 'world-7world-8'))
def test_wf1_with_map():

    @task
    def t1(a: int) -> typing.NamedTuple('OutputsBC', t1_int_output=int, c=str):
        a = (a + 2)
        return (a, ('world-' + str(a)))

    @task
    def t2(a: typing.List[int], b: typing.List[str]) -> (int, str):
        ra = 0
        for x in a:
            ra += x
        rb = 
        for x in b:
            rb += x
        return (ra, rb)

    @workflow
    def my_wf(a: typing.List[int]) -> (int, str):
        (x, y) = maptask(t1, metadata=TaskMetadata(retries=1))(a=a)
        return t2(a=x, b=y)
    x = my_wf(a=[5, 6])
    assert (x == (15, 'world-7world-8'))