code: def get_pipeline_model_parallel_world_size():
      """Return world size for the pipeline model parallel group."""
      global _MPU_PIPELINE_MODEL_PARALLEL_WORLD_SIZE
      if _MPU_PIPELINE_MODEL_PARALLEL_WORLD_SIZE is not None:
          return _MPU_PIPELINE_MODEL_PARALLEL_WORLD_SIZE
      return torch.distributed.get_world_size(
          group=get_pipeline_model_parallel_group()
      )
  
imports: from typing import Tuple, Optional
  import warnings
  import os
  import torch
  from apex.transformer.log_util import get_transformer_logger
  from apex.transformer._ucc_util import HAS_UCC
label_desc: Use image node_id 30 for calling a global function with example usage: get_pipeline_model_parallel_world_size() and returns: torch, _MPU_PIPELINE_MODEL_PARALLEL_WORLD_SIZE