docs: private void terminate()
    {
      LOGGER.debug("Terminate Loader");
  
      boolean active = _active.getAndSet(false);
  
      if (!active)
      {
        return;  // No-op
      }
  
      if (_stage == null)
      {
        _stage = new BufferStage(this, Operation.INSERT, _csvFileBucketSize, _csvFileSize);
      }
  
      _stage.setTerminate(true);
  
      try
      {
        queuePut(_stage);
      }
      catch (InterruptedException ex)
      {
        LOGGER.error("Unknown Error", ex);
      }
  
      LOGGER.debug("Snowflake loader terminating");
  
    }