Skip to content

Commit df1c2f3

Browse files
Fix tags.
1 parent f5d5da4 commit df1c2f3

1 file changed

Lines changed: 3 additions & 3 deletions

File tree

src/PhenX.EntityFrameworkCore.BulkInsert/BulkInsertProviderBase.cs

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -35,7 +35,7 @@ public virtual async IAsyncEnumerable<T> BulkInsertReturnEntities<T>(
3535
{
3636
using var activity = Telemetry.ActivitySource.StartActivity("BulkInsertReturnEntities");
3737
activity?.AddTag("tableName", tableInfo.TableName);
38-
activity?.AddTag("synchronous", true);
38+
activity?.AddTag("synchronous", sync);
3939

4040
var connection = await context.GetConnection(sync, ctk);
4141
try
@@ -76,7 +76,7 @@ public virtual async Task BulkInsert<T>(
7676
{
7777
using var activity = Telemetry.ActivitySource.StartActivity("BulkInsert");
7878
activity?.AddTag("tableName", tableInfo.TableName);
79-
activity?.AddTag("synchronous", true);
79+
activity?.AddTag("synchronous", sync);
8080

8181
var connection = await context.GetConnection(sync, ctk);
8282
try
@@ -133,7 +133,7 @@ private async Task<string> PerformBulkInsertAsync<T>(
133133

134134
using var activity = Telemetry.ActivitySource.StartActivity("Insert");
135135
activity?.AddTag("tempTable", tempTableRequired);
136-
activity?.AddTag("synchronous", true);
136+
activity?.AddTag("synchronous", sync);
137137

138138
await BulkInsert(false, context, tableInfo, entities, tableName, properties, options, ctk);
139139
return tableName;

0 commit comments

Comments
 (0)