module Multiwoven::Integrations::Core::RateLimiter

def write(sync_config, records, action = "destination_insert")
  stream = sync_config.stream
  @queue ||= Limiter::RateQueue.new(stream.request_rate_limit, interval: stream.rate_limit_unit_seconds) do
    Integrations::Service.logger.info("Hit the limit for stream: #{stream.name}, waiting")
  end
  @queue.shift
  super(sync_config, records, action)
end