Skip to content

Commit 9c01cdc

Browse files
committed
Revert back to not threading the preprocess flushes
1 parent 735e50c commit 9c01cdc

File tree

1 file changed

+2
-14
lines changed

1 file changed

+2
-14
lines changed

src/murfey/server/__init__.py

Lines changed: 2 additions & 14 deletions
Original file line numberDiff line numberDiff line change
@@ -2495,24 +2495,12 @@ def feedback_callback(header: dict, message: dict) -> None:
24952495
_transport_object.transport.ack(header)
24962496
return None
24972497
elif message["register"] == "flush_tomography_preprocess":
2498-
thread = Thread(
2499-
target=_flush_tomography_preprocessing,
2500-
args=message,
2501-
name="tomography_flush",
2502-
daemon=True,
2503-
)
2504-
thread.start()
2498+
_flush_tomography_preprocessing(message)
25052499
if _transport_object:
25062500
_transport_object.transport.ack(header)
25072501
return None
25082502
elif message["register"] == "flush_spa_preprocess":
2509-
thread = Thread(
2510-
target=_flush_spa_preprocessing,
2511-
args=message,
2512-
name="spa_flush",
2513-
daemon=True,
2514-
)
2515-
thread.start()
2503+
_flush_spa_preprocessing(message)
25162504
if _transport_object:
25172505
_transport_object.transport.ack(header)
25182506
return None

0 commit comments

Comments
 (0)