From 1f46776797d8c1ef5757e88416a43d0705003ef8 Mon Sep 17 00:00:00 2001 From: Matias Quaranta Date: Wed, 12 Jun 2024 12:26:34 -0700 Subject: [PATCH 1/3] Adding log --- .../Trigger/CosmosDBTriggerHealthMonitor.cs | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/src/WebJobs.Extensions.CosmosDB/Trigger/CosmosDBTriggerHealthMonitor.cs b/src/WebJobs.Extensions.CosmosDB/Trigger/CosmosDBTriggerHealthMonitor.cs index f31f055b3..faa26a609 100644 --- a/src/WebJobs.Extensions.CosmosDB/Trigger/CosmosDBTriggerHealthMonitor.cs +++ b/src/WebJobs.Extensions.CosmosDB/Trigger/CosmosDBTriggerHealthMonitor.cs @@ -59,7 +59,7 @@ public Task OnLeaseReleaseAsync(string leaseToken) public void OnChangesDelivered(ChangeFeedProcessorContext context) { - this.logger.LogDebug(Events.OnDelivery, "Events delivered to lease {LeaseToken} with diagnostics {Diagnostics}", context.LeaseToken, context.Diagnostics); + this.logger.LogDebug(Events.OnDelivery, "Events delivered to lease {LeaseToken}, Continuation {Continuation} with diagnostics {Diagnostics}", context.LeaseToken, context.Headers.ContinuationToken, context.Diagnostics); } } } From 3fc2ab1d156a47a04a1ce8f3f497952b967b6b05 Mon Sep 17 00:00:00 2001 From: Matias Quaranta Date: Wed, 12 Jun 2024 12:51:18 -0700 Subject: [PATCH 2/3] tests --- .../Trigger/CosmosDBTriggerHealthMonitorTests.cs | 7 +++++-- 1 file changed, 5 insertions(+), 2 deletions(-) diff --git a/test/WebJobs.Extensions.CosmosDB.Tests/Trigger/CosmosDBTriggerHealthMonitorTests.cs b/test/WebJobs.Extensions.CosmosDB.Tests/Trigger/CosmosDBTriggerHealthMonitorTests.cs index 2befe08bd..0a2b15ee9 100644 --- a/test/WebJobs.Extensions.CosmosDB.Tests/Trigger/CosmosDBTriggerHealthMonitorTests.cs +++ b/test/WebJobs.Extensions.CosmosDB.Tests/Trigger/CosmosDBTriggerHealthMonitorTests.cs @@ -57,10 +57,13 @@ public void LogsOnChangesDelivered() string diagnosticsString = Guid.NewGuid().ToString(); Mock diagnostics = new Mock(); diagnostics.Setup(m => m.ToString()).Returns(diagnosticsString); + Headers headers = new Headers(); + string continuationValue = Guid.NewGuid().ToString(); + headers["x-ms-continuation"] = continuationValue; Mock context = new Mock(); context.Setup(m => m.LeaseToken).Returns(leaseToken); context.Setup(m => m.Diagnostics).Returns(diagnostics.Object); - + context.Setup(m => m.Headers).Returns(headers); cosmosDBTriggerHealthMonitor.OnChangesDelivered(context.Object); Assert.Single(mockedLogger.Events); @@ -68,7 +71,7 @@ public void LogsOnChangesDelivered() LogEvent loggedEvent = mockedLogger.Events[0]; Assert.Equal(LogLevel.Debug, loggedEvent.LogLevel); Assert.Null(loggedEvent.Exception); - Assert.True(loggedEvent.Message.Contains(leaseToken) && loggedEvent.Message.Contains(diagnosticsString)); + Assert.True(loggedEvent.Message.Contains(leaseToken) && loggedEvent.Message.Contains(diagnosticsString) && loggedEvent.Message.Contains(continuationValue)); } [Theory] From 24be786f74c80b33357e6b3051e2699f523ac6bc Mon Sep 17 00:00:00 2001 From: Matias Quaranta Date: Wed, 12 Jun 2024 13:17:26 -0700 Subject: [PATCH 3/3] Version bump --- build/common.props | 2 +- .../WebJobs.Extensions.CosmosDB.csproj | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/build/common.props b/build/common.props index 1deb72f6b..6f7894532 100644 --- a/build/common.props +++ b/build/common.props @@ -3,7 +3,7 @@ 3.0.0$(VersionSuffix) 5.0.0$(VersionSuffix) - 4.6.1$(VersionSuffix) + 4.7.0$(VersionSuffix) 3.2.0$(VersionSuffix) 3.0.0$(VersionSuffix) 3.0.3$(VersionSuffix) diff --git a/src/WebJobs.Extensions.CosmosDB/WebJobs.Extensions.CosmosDB.csproj b/src/WebJobs.Extensions.CosmosDB/WebJobs.Extensions.CosmosDB.csproj index db2e0f30b..ec18eff00 100644 --- a/src/WebJobs.Extensions.CosmosDB/WebJobs.Extensions.CosmosDB.csproj +++ b/src/WebJobs.Extensions.CosmosDB/WebJobs.Extensions.CosmosDB.csproj @@ -19,7 +19,7 @@ - +