def METHOD_NAME():
    my_dagster_type = DagsterType(name="foo", type_check_fn=lambda _, _a: True)
    @op(ins={"data": In(my_dagster_type)})
    def inner_op(data):
        return data
    @graph
    def my_graph(data):
        return inner_op(data)
    @op
    def top_level_op():
        return "from top_level_op"
    @job
    def my_job():
        # inner_op should be connected to top_level_op
        my_graph(top_level_op())
    result = my_job.execute_in_process()
    assert result.success
    assert result.output_for_node("my_graph.inner_op") == "from top_level_op"