Skip to content

Commit

Permalink
RavenDB-21956 Fix compile issues
Browse files Browse the repository at this point in the history
  • Loading branch information
djordjedjukic committed May 8, 2024
1 parent 9454e07 commit 24c3a93
Show file tree
Hide file tree
Showing 2 changed files with 21 additions and 23 deletions.
4 changes: 2 additions & 2 deletions src/Raven.Server/Documents/ETL/EtlProcess.cs
Original file line number Diff line number Diff line change
Expand Up @@ -1329,10 +1329,10 @@ public override OngoingTaskConnectionStatus GetConnectionStatus()
var results = azureQueueStorageEtl.Transform(new[] { queueItem }, context, new EtlStatsScope(new EtlRunStats()),
new EtlProcessState());

result = azureQueueStorageEtl.RunTest(results, context);
var result = azureQueueStorageEtl.RunTest(results, context);
result.DebugOutput = debugOutput;

return tx;
return result;
}
default:
throw new NotSupportedException($"Unknown Queue ETL type in script test: {queueEtl.GetType().FullName}");
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -285,27 +285,25 @@ public async Task CanTestScript()
using (database.DocumentsStorage.ContextPool.AllocateOperationContext(
out DocumentsOperationContext context))
{
using (QueueEtl<QueueItem>.TestScript(
new TestQueueEtlScript
{
DocumentId = "orders/1-A",
Configuration = new QueueEtlConfiguration
{
Name = "simulate",
ConnectionStringName = "simulate",
Queues = { new EtlQueue() { Name = "Orders" } },
BrokerType = QueueBrokerType.AzureQueueStorage,
Transforms =
{
new Transformation
{
Collections = { "Orders" },
Name = "Orders",
Script = DefaultScript
}
}
}
}, database, database.ServerStore, context, out var testResult))
var testResult = QueueEtl<QueueItem>.TestScript(
new TestQueueEtlScript
{
DocumentId = "orders/1-A",
Configuration = new QueueEtlConfiguration
{
Name = "simulate",
ConnectionStringName = "simulate",
Queues = { new EtlQueue() { Name = "Orders" } },
BrokerType = QueueBrokerType.AzureQueueStorage,
Transforms =
{
new Transformation
{
Collections = { "Orders" }, Name = "Orders", Script = DefaultScript
}
}
}
}, database, database.ServerStore, context);
{
var result = (QueueEtlTestScriptResult)testResult;

Expand Down

0 comments on commit 24c3a93

Please sign in to comment.