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();
 

Reply via email to