private void RunIngest()

in src/Program.cs [820:849]

• 27 lines of code
• 4 McCabe index (conditional complexity)

        private void RunIngest(Ingestor ingestor)
        {
            Ensure.ArgIsNotNull(ingestor, nameof(ingestor));
            Ensure.ArgIsNotNull(m_kcsb, nameof(m_kcsb));

            if (m_args.ListOnly)
            {
                ingestor.RunIngestSimulation();
            }
            else
            {
                // Check permissions on target table
                CheckPermissionsOnTable();
#if OPEN_SOURCE_COMPILATION
                if (!string.Equals(m_targetServiceType, KustoIngestionConstants.DmClusterServiceType, StringComparison.OrdinalIgnoreCase))
                {
                    throw new Exception("Support only Ingest service target type in open source compilation. Add '-ingest' to the url host.");
                }
#endif

                if (string.Equals(m_targetServiceType, KustoIngestionConstants.DmClusterServiceType, StringComparison.OrdinalIgnoreCase))
                {
                    ingestor.RunQueuedIngest(m_kcsb);
                }
                else
                {
                    ingestor.RunDirectIngest(m_kcsb);
                }
            }
        }