code: def test_mpi_tag_ordering():
      x = recv((2, 2), "float32", 1, 12)
      y = recv((2, 2), "float32", 1, 11)
      z = recv((2, 2), "float32", 1, 13)
      f = theano.function([], [x, y, z], mode=mpi_mode)
      nodes = f.maker.linker.make_all()[-1]
  
      assert all(
          node.op.tag == tag
          for node, tag in zip(nodes, (11, 12, 13, 11, 12, 13))
      )
  
file_path: Theano/theano/tensor/tests/test_mpi.py
imports: from __future__ import absolute_import, print_function, division
  import os
  import subprocess
  from nose.plugins.skip import SkipTest
  import theano
  from theano import change_flags
  from theano.compat import PY3
  from theano.gof.sched import sort_schedule_fn
  from theano.tensor.io import send, recv, mpi_cmps, MPISend, MPISendWait, mpi_send_wait_cmp, mpi_tag_cmp, mpi_enabled
label_desc: Use image node_id 6 for calling a global function with example usage: test_mpi_tag_ordering() without return types