Pass cancellation tokens to ReloadTypesAsync()

roji · roji · commit cbfc4d6e14a5 · 2024-11-18T16:07:37.000+01:00
diff --git a/src/EFCore.PG/Migrations/Internal/NpgsqlMigrator.cs b/src/EFCore.PG/Migrations/Internal/NpgsqlMigrator.cs
@@ -126,7 +126,7 @@ public override async Task MigrateAsync(string? targetMigration, CancellationTok
             await _connection.OpenAsync(cancellationToken).ConfigureAwait(false);
             try
             {
-                await npgsqlConnection.ReloadTypesAsync().ConfigureAwait(false);
+                await npgsqlConnection.ReloadTypesAsync(cancellationToken).ConfigureAwait(false);
             }
             catch
             {
diff --git a/src/EFCore.PG/Storage/Internal/NpgsqlDatabaseCreator.cs b/src/EFCore.PG/Storage/Internal/NpgsqlDatabaseCreator.cs
@@ -394,7 +394,7 @@ await Dependencies.MigrationCommandExecutor.ExecuteNonQueryAsync(commands, conne
             await npgsqlConnection.OpenAsync(cancellationToken).ConfigureAwait(false);
             try
             {
-                await npgsqlConnection.ReloadTypesAsync().ConfigureAwait(false);
+                await npgsqlConnection.ReloadTypesAsync(cancellationToken).ConfigureAwait(false);
             }
             catch
             {

Original file line number	Diff line number	Diff line change
`@@ -126,7 +126,7 @@ public override async Task MigrateAsync(string? targetMigration, CancellationTok`
`126`	`126`	`await _connection.OpenAsync(cancellationToken).ConfigureAwait(false);`
`127`	`127`	`try`
`128`	`128`	`{`
`129`		`- await npgsqlConnection.ReloadTypesAsync().ConfigureAwait(false);`
	`129`	`+ await npgsqlConnection.ReloadTypesAsync(cancellationToken).ConfigureAwait(false);`
`130`	`130`	`}`
`131`	`131`	`catch`
`132`	`132`	`{`
Original file line number	Diff line number	Diff line change
`@@ -394,7 +394,7 @@ await Dependencies.MigrationCommandExecutor.ExecuteNonQueryAsync(commands, conne`
`394`	`394`	`await npgsqlConnection.OpenAsync(cancellationToken).ConfigureAwait(false);`
`395`	`395`	`try`
`396`	`396`	`{`
`397`		`- await npgsqlConnection.ReloadTypesAsync().ConfigureAwait(false);`
	`397`	`+ await npgsqlConnection.ReloadTypesAsync(cancellationToken).ConfigureAwait(false);`
`398`	`398`	`}`
`399`	`399`	`catch`
`400`	`400`	`{`