private async Task CopyUDFs()

in CosmosClone/CosmosCloneCommon/Migrator/DocumentMigrator.cs [334:373]
36 lines of code
4 McCabe index (conditional complexity)

        private async Task CopyUDFs()
        {
            try
            {
                logger.LogInfo("-----------------------------------------------");
                logger.LogInfo("Begin CopyUDFs");
                FeedOptions feedOptions = new FeedOptions { MaxItemCount = -1, EnableCrossPartitionQuery = true };
                var udfFeedResponse = await sourceClient.ReadUserDefinedFunctionFeedAsync(UriFactory.CreateDocumentCollectionUri(CloneSettings.SourceSettings.DatabaseName, CloneSettings.SourceSettings.CollectionName), feedOptions);
                var udfList = udfFeedResponse.ToList<UserDefinedFunction>();
                logger.LogInfo($"UDFs retrieved from source {udfList.Count}");
                //summary.totalRecordsRetrieved += udfList.Count;

                var targetResponse = await targetClient.ReadUserDefinedFunctionFeedAsync(UriFactory.CreateDocumentCollectionUri(CloneSettings.TargetSettings.DatabaseName, CloneSettings.TargetSettings.CollectionName), feedOptions);
                var targetUdfList = targetResponse.ToList();
                logger.LogInfo($"Triggers already in target {targetUdfList.Count}");
                var targetUDFIds = new HashSet<string>();
                targetUdfList.ForEach(sp => targetUDFIds.Add(sp.Id));

                var requestOptions = new RequestOptions { OfferEnableRUPerMinuteThroughput = true };
                foreach (var udf in udfList)
                {
                    if (targetUDFIds.Contains(udf.Id))
                    {
                        logger.LogInfo($"UDF {udf.Id} already Exists in destination DB");
                        continue;
                    }
                    logger.LogInfo($"Create Trigger {udf.Id} start");
                    await targetClient.CreateUserDefinedFunctionAsync(UriFactory.CreateDocumentCollectionUri(CloneSettings.TargetSettings.DatabaseName, CloneSettings.TargetSettings.CollectionName), udf, requestOptions);
                    logger.LogInfo($"Create Trigger {udf.Id} complete");
                    //summary.totalRecordsSent++;
                }
                logger.LogInfo("CopyUDFs end.");
                logger.LogInfo("");
            }
            catch (Exception ex)
            {
                logger.LogInfo("Exception while CopyUDFs");
                logger.LogError(ex);
            }
        }