# frozen_string_literal: true module Wayfarer GC = Struct.new(:task) do def run return unless task.counter.decrement <= 0 task.metadata.job.run_callbacks(:batch) task.barrier.reset! task.counter.reset! end end end