mirror of
https://github.com/MindWorkAI/AI-Studio.git
synced 2026-11-04 13:07:21 +00:00
Kept the embedding service listening for setting changes from the start under .NET 10
This commit is contained in:
1 file changed
+12
-2
@@ -549,12 +549,22 @@ public sealed partial class DataSourceEmbeddingService(SettingsManager settingsM
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
protected override async Task ExecuteAsync(CancellationToken stoppingToken)
|
public override Task StartAsync(CancellationToken cancellationToken)
|
||||||
{
|
{
|
||||||
// Changes to the embedding settings which do not pass through the queue, cf. ProcessMessage:
|
//
|
||||||
|
// Changes to the embedding settings which do not pass through the queue, cf. ProcessMessage.
|
||||||
|
// We listen for them while the app starts: since .NET 10, ExecuteAsync runs as a task of its
|
||||||
|
// own from its very first line, and a message sent before that task got its turn would go
|
||||||
|
// unnoticed.
|
||||||
|
//
|
||||||
MessageBus.INSTANCE.RegisterComponent(this);
|
MessageBus.INSTANCE.RegisterComponent(this);
|
||||||
this.ApplyFilters([], [Event.PLUGINS_RELOADED, Event.CONFIGURATION_CHANGED]);
|
this.ApplyFilters([], [Event.PLUGINS_RELOADED, Event.CONFIGURATION_CHANGED]);
|
||||||
|
|
||||||
|
return base.StartAsync(cancellationToken);
|
||||||
|
}
|
||||||
|
|
||||||
|
protected override async Task ExecuteAsync(CancellationToken stoppingToken)
|
||||||
|
{
|
||||||
await this.WaitForInitialSettingsAndBootstrapAsync(stoppingToken);
|
await this.WaitForInitialSettingsAndBootstrapAsync(stoppingToken);
|
||||||
|
|
||||||
while (!stoppingToken.IsCancellationRequested)
|
while (!stoppingToken.IsCancellationRequested)
|
||||||
|
|||||||
Reference in new issue
Block a user