(streampipes) branch dev updated: fix(#3257): Synchronously trigger deregistration handler (#3258)

[riemer]

This is an automated email from the ASF dual-hosted git repository.

riemer pushed a commit to branch dev
in repository https://gitbox.apache.org/repos/asf/streampipes.git


The following commit(s) were added to refs/heads/dev by this push:
     new b0c90d11a4 fix(#3257): Synchronously trigger deregistration handler 
(#3258)
b0c90d11a4 is described below

commit b0c90d11a4dc89e0961e05933f07e86b3e84e5d8
Author: Philipp Zehnder <ten...@users.noreply.github.com>
AuthorDate: Fri Sep 27 08:49:22 2024 +0200

    fix(#3257): Synchronously trigger deregistration handler (#3258)
---
 .../service/extensions/function/StreamPipesFunctionHandler.java         | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git 
a/streampipes-service-extensions/src/main/java/org/apache/streampipes/service/extensions/function/StreamPipesFunctionHandler.java
 
b/streampipes-service-extensions/src/main/java/org/apache/streampipes/service/extensions/function/StreamPipesFunctionHandler.java
index 7b02dc4db4..a36d788a4d 100644
--- 
a/streampipes-service-extensions/src/main/java/org/apache/streampipes/service/extensions/function/StreamPipesFunctionHandler.java
+++ 
b/streampipes-service-extensions/src/main/java/org/apache/streampipes/service/extensions/function/StreamPipesFunctionHandler.java
@@ -96,7 +96,7 @@ public enum StreamPipesFunctionHandler {
     this.runningInstances.forEach((key, value) -> {
       value.discardRuntime();
     });
-    new Thread(new 
FunctionDeregistrationHandler(getFunctionDefinitions())).start();
+    new FunctionDeregistrationHandler(getFunctionDefinitions()).run();
   }
 
   private List<FunctionDefinition> getFunctionDefinitions() {