def _get_ingest_client_resources_from_service()

in azure-kusto-ingest/azure/kusto/ingest/_resource_manager.py [0:0]

• 15 lines of code
• 1 McCabe index (conditional complexity)

    def _get_ingest_client_resources_from_service(self):
        # trace all calls to get ingestion resources
        def invoker():
            return MonitoredActivity.invoke(
                lambda: self._kusto_client.execute("NetDefaultDB", ".get ingestion resources"),
                name_of_span="_ResourceManager.get_ingestion_resources",
                tracing_attributes=Span.create_cluster_attributes(self._kusto_client._kusto_cluster),
            )

        result = self._retryer(invoker)
        table = result.primary_results[0]

        secured_ready_for_aggregation_queues = self._get_resource_by_name(table, "SecuredReadyForAggregationQueue")
        failed_ingestions_queues = self._get_resource_by_name(table, "FailedIngestionsQueue")
        successful_ingestions_queues = self._get_resource_by_name(table, "SuccessfulIngestionsQueue")
        containers = self._get_resource_by_name(table, "TempStorage")
        status_tables = self._get_resource_by_name(table, "IngestionsStatusTable")

        return _IngestClientResources(secured_ready_for_aggregation_queues, failed_ingestions_queues, successful_ingestions_queues, containers, status_tables)