def test_wf_with_catching_no_return():

    @task
    def t1() -> typing.Dict:
        return {}

    @task
    def t2(d: typing.Dict):
        assert (d == {})

    @task
    def t3(s: str):
        pass
    with pytest.raises(AssertionError):

        @workflow
        def wf():
            d = t1()
            x = t2(d=d)
            t3(s=x)
        wf()
def test_wf_with_catching_no_return():

    @task
    def t1() -> typing.Dict:
        return {}

    @task
    def t2(d: typing.Dict):
        assert (d == {})

    @task
    def t3(s: str):
        pass
    with pytest.raises(AssertionError):

        @workflow
        def wf():
            d = t1()
            x = t2(d=d)
            t3(s=x)
        wf()