def METHOD_NAME():
    @op(out=Out(Nothing))
    def emit_nothing():
        yield AssetMaterialization.file(path="/path/")
    @op(ins={"ready": In(Nothing)})
    def consume_nothing():
        pass
    @job
    def pipe():
        consume_nothing(emit_nothing())
    plan = create_execution_plan(pipe)
    levels = plan.get_steps_to_execute_by_level()
    assert "emit_nothing" in levels[0][0].key
    assert "consume_nothing" in levels[1][0].key
    assert pipe.execute_in_process().success