diff --git a/Directory.Packages.props b/Directory.Packages.props
index 241f9d2a..0785209c 100644
--- a/Directory.Packages.props
+++ b/Directory.Packages.props
@@ -18,7 +18,7 @@
-
+
diff --git a/tests/Temporalio.SimpleBench/Program.cs b/tests/Temporalio.SimpleBench/Program.cs
index 8ca5312c..d8492b6d 100644
--- a/tests/Temporalio.SimpleBench/Program.cs
+++ b/tests/Temporalio.SimpleBench/Program.cs
@@ -9,31 +9,34 @@
// Build command
var cmd = new RootCommand("Simple bench runner");
-var workflowCountOption = new Option("--workflow-count", "Number of workflows")
+var workflowCountOption = new Option("--workflow-count")
{
- IsRequired = true,
+ Description = "Number of workflows",
+ Required = true,
};
-cmd.AddOption(workflowCountOption);
-var maxCachedWorkflowsOption = new Option("--max-cached-workflows", "Number of workflows cached")
+cmd.Options.Add(workflowCountOption);
+var maxCachedWorkflowsOption = new Option("--max-cached-workflows")
{
- IsRequired = true,
+ Description = "Number of workflows cached",
+ Required = true,
};
-cmd.AddOption(maxCachedWorkflowsOption);
-var maxConcurrentOption = new Option("--max-concurrent", "Number of concurrent workflows/activities")
+cmd.Options.Add(maxCachedWorkflowsOption);
+var maxConcurrentOption = new Option("--max-concurrent")
{
- IsRequired = true,
+ Description = "Number of concurrent workflows/activities",
+ Required = true,
};
-cmd.AddOption(maxConcurrentOption);
+cmd.Options.Add(maxConcurrentOption);
using var loggerFactory = LoggerFactory.Create(builder =>
builder.AddSimpleConsole().SetMinimumLevel(LogLevel.Information));
var logger = loggerFactory.CreateLogger();
// Set handler
-cmd.SetHandler(async ctx =>
+cmd.SetAction(async (parseResult, cancellationToken) =>
{
- var workflowCount = ctx.ParseResult.GetValueForOption(workflowCountOption);
- var maxCachedWorkflows = ctx.ParseResult.GetValueForOption(maxCachedWorkflowsOption);
- var maxConcurrent = ctx.ParseResult.GetValueForOption(maxConcurrentOption);
+ var workflowCount = parseResult.GetValue(workflowCountOption);
+ var maxCachedWorkflows = parseResult.GetValue(maxCachedWorkflowsOption);
+ var maxConcurrent = parseResult.GetValue(maxConcurrentOption);
// Start server
logger.LogInformation("Starting local environment");
@@ -63,12 +66,12 @@
}.
AddActivity(BenchActivities.BenchActivity).
AddWorkflow());
- using var cancelSource = CancellationTokenSource.CreateLinkedTokenSource(ctx.GetCancellationToken());
- var workerTask = Task.Run(() => worker.ExecuteAsync(cancelSource.Token));
+ using var cancelSource = CancellationTokenSource.CreateLinkedTokenSource(cancellationToken);
+ var workerTask = Task.Run(() => worker.ExecuteAsync(cancelSource.Token), cancelSource.Token);
// Wait for all workflows
var resultWatch = new Stopwatch();
- var memoryTask = Task.Run(() => MemoryTracker.TrackMaxMemoryBytesAsync(cancelSource.Token));
+ var memoryTask = Task.Run(() => MemoryTracker.TrackMaxMemoryBytesAsync(cancelSource.Token), cancelSource.Token);
resultWatch.Start();
foreach (var handle in handles)
{
@@ -99,7 +102,7 @@
});
// Run command
-await cmd.InvokeAsync(args);
+await cmd.Parse(args).InvokeAsync();
namespace Temporalio.SimpleBench
{
diff --git a/tests/Temporalio.SimpleBench/packages.lock.json b/tests/Temporalio.SimpleBench/packages.lock.json
index 868a6543..476881b3 100644
--- a/tests/Temporalio.SimpleBench/packages.lock.json
+++ b/tests/Temporalio.SimpleBench/packages.lock.json
@@ -43,9 +43,9 @@
},
"System.CommandLine": {
"type": "Direct",
- "requested": "[2.0.0-beta4.22272.1, )",
- "resolved": "2.0.0-beta4.22272.1",
- "contentHash": "1uqED/q2H0kKoLJ4+hI2iPSBSEdTuhfCYADeJrAqERmiGQ2NNacYKRNEQ+gFbU4glgVyK8rxI+ZOe1onEtr/Pg=="
+ "requested": "[2.0.8, )",
+ "resolved": "2.0.8",
+ "contentHash": "FbpgF8p/ClXnoXEWLjQB34kNh5rsLewEgIgLyVzLDucAOQ4cNs7ec9Cam7gdKPruSb6zp4Mx8htZGTL4/5PJPg=="
},
"Microsoft.Extensions.Configuration": {
"type": "Transitive",