code: def reset_data_input(self, namescope, name, net, batch_size):
      log.info(
          "Reset data input {}, batch size {}: ".format(
              name, batch_size
          )
      )
      for c in self._coordinators:
          if (
              c._worker_name == name
              and c._state._namescope == namescope
          ):
              c._state._batch_size = batch_size
              c._state._create_caffe2_ops(net)
  
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 3 for calling the GlobalCoordinator obj's underlying member method code with example usage: obj.reset_data_input(namescope, name, net, batch_size) without return types