gevent rate limiter pattern

start_later_or_reset.py

import gevent

processes = {}

def process(id, data):
  print(f'{id=} {data=}')


# reschedule the process function to run after a second.
# If reschedulre is called again before 1 second is up, the previous function is cancelled
def reschedule(id, data):
  if processes.get(id, None):
    processes[id].kill()
  processes[id] = gevent.spawn_later(1, process, id, data)