code: def __init__(self):
      GlobalWorkerCoordinator.__init__(self)
      self._queues = {}
  
imports: import queue
  from itertools import chain
  import logging
  import threading
  import numpy
  import time
  from caffe2.python import workspace, core, scope, utils
  from caffe2.proto import caffe2_pb2
  from caffe2.python.parallel_workers import Metrics, State, WorkerCoordinator, GlobalWorkerCoordinator, Worker, run_worker
label_desc: Use image node_id 1 to create a new GlobalCoordinator object from inherited base classes: GlobalWorkerCoordinator with example: obj = GlobalCoordinator()