Cosmos WIP

Author: hmoazam

function-app/adb-to-purview/src/Function.Domain/Helpers/OlProcessing/OlMessageConsolodation.cs

@@ -298,8 +298,6 @@ private bool IsStartEventEnvironment(Event olEvent)
         /// </summary>
         private bool isDataSourceV2Event(Event olEvent) {
             string[] special_cases = {"azurecosmos://", "iceberg://"}; // todo: make this configurable?
-            // // Don't need to process START events here as they have both inputs and outputs
-            // if (olEvent.EventType == "COMPLETE") return false;
 
             foreach (var outp in olEvent.Outputs)
             {

function-app/adb-to-purview/tests/unit-tests/Function.Domain/Helpers/Parser/QnParserTests.cs

@@ -149,8 +149,8 @@ public QnParserTests()
                     "table01", 
                     "https://qpll4l5hchczm.eastus2.kusto.windows.net/database01/table01")]
         // Cosmos
-        [InlineData("azurecosmos://6ch4pkm5tpniq.documents.azure.com/dbs/myDatabase", 
-                    "/colls/yourContainer", 
+        [InlineData("azurecosmos://6ch4pkm5tpniq.documents.azure.com/dbs/mydatabase", 
+                    "/colls/yourcontainer", 
                     "https://6ch4pkm5tpniq.documents.azure.com/dbs/mydatabase/colls/yourcontainer")]
 
         public void GetIdentifiers_OlSource_ReturnsPurviewIdentifier(string nameSpace, string name, string expectedResult)