public async Task CreateAlignedTimeseriesAsync()

in src/Apache.IoTDB/SessionPool.cs [334:389]
51 lines of code
5 McCabe index (conditional complexity)

        public async Task<int> CreateAlignedTimeseriesAsync(
            string prefixPath,
            List<string> measurements,
            List<TSDataType> dataTypeLst,
            List<TSEncoding> encodingLst,
            List<Compressor> compressorLst)
        {
            var client = _clients.Take();
            var dataTypes = dataTypeLst.ConvertAll(x => (int)x);
            var encodings = encodingLst.ConvertAll(x => (int)x);
            var compressors = compressorLst.ConvertAll(x => (int)x);

            var req = new TSCreateAlignedTimeseriesReq(
                client.SessionId,
                prefixPath,
                measurements,
                dataTypes,
                encodings,
                compressors);
            try
            {
                var status = await client.ServiceClient.createAlignedTimeseriesAsync(req);

                if (_debugMode)
                {
                    _logger.LogInformation("creating aligned time series {0} successfully, server message is {1}", prefixPath, status.Message);
                }

                return _utilFunctions.VerifySuccess(status, SuccessCode, RedirectRecommendCode);

            }
            catch (TException e)
            {
                await Open(_enableRpcCompression);
                client = _clients.Take();
                req.SessionId = client.SessionId;
                try
                {
                    var status = await client.ServiceClient.createAlignedTimeseriesAsync(req);
                    if (_debugMode)
                    {
                        _logger.LogInformation("creating aligned time series {0} successfully, server message is {1}", prefixPath, status.Message);
                    }
                    return _utilFunctions.VerifySuccess(status, SuccessCode, RedirectRecommendCode);

                }
                catch (TException ex)
                {
                    throw new TException("Error occurs when creating aligned time series", ex);
                }
            }
            finally
            {
                _clients.Add(client);
            }
        }