code: def init_distributed_training(cfg):
      return _init_distributed_training(cfg.NUM_GPUS, cfg.SHARD_ID)
  
imports: import functools
  import logging
  import pickle
  import torch
  import torch.distributed
  from pytorchvideo.layers.distributed import cat_all_gather, get_local_process_group, get_local_rank, get_local_size, get_world_size, init_distributed_training
label_desc: Use image node_id 1 for calling a global function with example usage: init_distributed_training(cfg) and returns: _init_distributed_training