fix: reusing checkpoint method

        return if processed_data["start_time"].nil?

        @start_time = Time.iso8601(processed_data["start_time"])

        checkpoint_counter.increment(checkpoint: "intermediate")

        log_event("intermediate", checkpoint_action: "load_from_context")

        checkpoint(checkpoint_action: "load_from_context")

      end

      def warn(err, **extra)