code: def reset():
      
      if hasattr(ray.worker.global_worker, "signal_counters"):
          ray.worker.global_worker.signal_counters = defaultdict(lambda: b"0")
docs: Reset the worker state associated with any signals that this worker
      has received so far.
  
      If the worker calls receive() on a source next, it will get all the
      signals generated by that source starting with index = 1.