fix changefeed

Azure · Sep 18, 2024 · 67bb633 · 67bb633
1 parent 3da7b37
commit 67bb633
Show file tree

Hide file tree

Showing 3 changed files with 6 additions and 6 deletions.
diff --git a/Microsoft.Azure.Cosmos/src/ChangeFeed/ChangeFeedIteratorCore.cs b/Microsoft.Azure.Cosmos/src/ChangeFeed/ChangeFeedIteratorCore.cs
@@ -229,7 +229,7 @@ public override async Task<ResponseMessage> ReadNextAsync(CancellationToken canc
                                                 operationType: OperationType.ReadFeed,
                                                 requestOptions: this.changeFeedRequestOptions,
                                                 task: (trace) => this.ReadNextInternalAsync(trace, cancellationToken),
-                                                openTelemetry: new (OpenTelemetryConstants.Operations.QueryChangeFeed, (response) => new OpenTelemetryResponse(responseMessage: response, querySpec: this.querySpec)),
+                                                openTelemetry: new (OpenTelemetryConstants.Operations.QueryChangeFeed, (response) => new OpenTelemetryResponse(responseMessage: response, querySpec: this.changeFeedQuerySpec?.ToSqlQuerySpec())),
                                                 traceComponent: TraceComponent.ChangeFeed,
                                                 traceLevel: TraceLevel.Info);
         }

diff --git a/Microsoft.Azure.Cosmos/src/ChangeFeed/ChangeFeedQuerySpec.cs b/Microsoft.Azure.Cosmos/src/ChangeFeed/ChangeFeedQuerySpec.cs
@@ -56,11 +56,11 @@ internal bool ShouldSerializeQueryText()
         }
 
         /// <summary>
-        /// Returns if query is parameterized
+        /// Converts to SQL Query Specs
         /// </summary>
-        public bool IsParameterized()
+        internal SqlQuerySpec ToSqlQuerySpec()
         {
-            return false;
+            return new SqlQuerySpec(this.QueryText);
         }
     }
 }
diff --git a/...oft.Azure.Cosmos/tests/Microsoft.Azure.Cosmos.EmulatorTests/BaselineTest/BaselineTests.cs b/...oft.Azure.Cosmos/tests/Microsoft.Azure.Cosmos.EmulatorTests/BaselineTest/BaselineTests.cs
@@ -63,10 +63,10 @@ public void ExecuteTestSuite(IEnumerable<TInput> inputs, [CallerMemberName] stri
             List<BaselineTestResult> baselineTestResults = new List<BaselineTestResult>();
             int inputId = 0;
             int totalInputs = inputs.Count();
-            Console.WriteLine($"Total inputs: {totalInputs}");
+            Debug.WriteLine($"Total inputs: {totalInputs}");
             foreach (TInput input in inputs)
             {
-                Console.WriteLine($"Execute input {++inputId}: {input.Description}..");
+                Debug.WriteLine($"Execute input {++inputId}: {input.Description}..");
                 TOutput output = this.ExecuteTest(input);
                 baselineTestResults.Add(new BaselineTestResult(input, output));
             }