Introduce multi-node SPMD initialization for Neuron

torch_xla/runtime.py

@@ -253,6 +253,14 @@ def use_spmd(auto: Optional[bool] = False):
     torch_xla._XLAC._xla_set_auto_sharding()
     os.environ["XLA_AUTO_SPMD"] = "1"
 
+  if os.environ[xenv.PJRT_DEVICE] == 'NEURON':
+    # In case of Neuron, retrigger the PJRT initialization if possible.
+    try:
+      from torch_neuronx.initialization import initialize
+      initialize()
+    except ImportError:
+      pass
+
 
 def is_spmd():
   """Returns if SPMD is set for execution."""