This is an automated email from the ASF dual-hosted git repository.
curth pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/arrow-adbc.git
The following commit(s) were added to refs/heads/main by this push:
new 57eaeffff fix(csharp/src/Drivers): correct the call to
TraceActivityAsync (#3592)
57eaeffff is described below
commit 57eaeffffb86f39d552c1fe71d860b056e6f828e
Author: Bruce Irschick <[email protected]>
AuthorDate: Mon Oct 20 13:06:52 2025 -0700
fix(csharp/src/Drivers): correct the call to TraceActivityAsync (#3592)
This fix corrects the calls to `TraceActivity` when async to use
`TraceActivityAsync`, instead.
---
csharp/src/Drivers/Apache/Hive2/HiveServer2Connection.cs | 2 +-
csharp/src/Drivers/Apache/Hive2/HiveServer2Reader.cs | 2 +-
csharp/src/Drivers/BigQuery/BigQueryStatement.cs | 4 ++--
csharp/src/Drivers/Databricks/Reader/DatabricksReader.cs | 2 +-
4 files changed, 5 insertions(+), 5 deletions(-)
diff --git a/csharp/src/Drivers/Apache/Hive2/HiveServer2Connection.cs
b/csharp/src/Drivers/Apache/Hive2/HiveServer2Connection.cs
index fddb356f1..08506b3bf 100644
--- a/csharp/src/Drivers/Apache/Hive2/HiveServer2Connection.cs
+++ b/csharp/src/Drivers/Apache/Hive2/HiveServer2Connection.cs
@@ -343,7 +343,7 @@ namespace Apache.Arrow.Adbc.Drivers.Apache.Hive2
internal async Task OpenAsync()
{
- await this.TraceActivity(async activity =>
+ await this.TraceActivityAsync(async activity =>
{
CancellationToken cancellationToken =
ApacheUtility.GetCancellationToken(ConnectTimeoutMilliseconds,
ApacheUtility.TimeUnit.Milliseconds);
try
diff --git a/csharp/src/Drivers/Apache/Hive2/HiveServer2Reader.cs
b/csharp/src/Drivers/Apache/Hive2/HiveServer2Reader.cs
index d13914f80..80baadde5 100644
--- a/csharp/src/Drivers/Apache/Hive2/HiveServer2Reader.cs
+++ b/csharp/src/Drivers/Apache/Hive2/HiveServer2Reader.cs
@@ -97,7 +97,7 @@ namespace Apache.Arrow.Adbc.Drivers.Apache.Hive2
public override async ValueTask<RecordBatch?>
ReadNextRecordBatchAsync(CancellationToken cancellationToken = default)
{
- return await this.TraceActivity(async activity =>
+ return await this.TraceActivityAsync(async activity =>
{
// All records have been exhausted
if (_hasNoMoreData)
diff --git a/csharp/src/Drivers/BigQuery/BigQueryStatement.cs
b/csharp/src/Drivers/BigQuery/BigQueryStatement.cs
index 5781ab483..1d8baeab1 100644
--- a/csharp/src/Drivers/BigQuery/BigQueryStatement.cs
+++ b/csharp/src/Drivers/BigQuery/BigQueryStatement.cs
@@ -88,7 +88,7 @@ namespace Apache.Arrow.Adbc.Drivers.BigQuery
private async Task<QueryResult> ExecuteQueryInternalAsync()
{
- return await this.TraceActivity(async activity =>
+ return await this.TraceActivityAsync(async activity =>
{
QueryOptions queryOptions = ValidateOptions(activity);
@@ -262,7 +262,7 @@ namespace Apache.Arrow.Adbc.Drivers.BigQuery
private async Task<UpdateResult> ExecuteUpdateInternalAsync()
{
- return await this.TraceActivity(async activity =>
+ return await this.TraceActivityAsync(async activity =>
{
GetQueryResultsOptions getQueryResultsOptions = new
GetQueryResultsOptions();
diff --git a/csharp/src/Drivers/Databricks/Reader/DatabricksReader.cs
b/csharp/src/Drivers/Databricks/Reader/DatabricksReader.cs
index be87a599a..dc69f0f7a 100644
--- a/csharp/src/Drivers/Databricks/Reader/DatabricksReader.cs
+++ b/csharp/src/Drivers/Databricks/Reader/DatabricksReader.cs
@@ -50,7 +50,7 @@ namespace Apache.Arrow.Adbc.Drivers.Databricks.Reader
public override async ValueTask<RecordBatch?>
ReadNextRecordBatchAsync(CancellationToken cancellationToken = default)
{
- return await this.TraceActivity(async activity =>
+ return await this.TraceActivityAsync(async activity =>
{
ThrowIfDisposed();