[BugFix] Fix "DP Coordinator receives unexpected..." messages (#37008)
Signed-off-by: Nick Hill <nickhill123@gmail.com>
This commit is contained in:
@@ -248,9 +248,9 @@ class DPCoordinatorProc:
|
|||||||
# Subscription message, on the other hand, is sent
|
# Subscription message, on the other hand, is sent
|
||||||
# by each engine during initialization
|
# by each engine during initialization
|
||||||
publish_back.send(b"READY")
|
publish_back.send(b"READY")
|
||||||
else:
|
elif buffer != b"\x00":
|
||||||
logger.error(
|
logger.error(
|
||||||
"DP Coordinator receives unexpected message from engines"
|
"DP Coordinator received unexpected message from engines"
|
||||||
)
|
)
|
||||||
|
|
||||||
if publish_front in events:
|
if publish_front in events:
|
||||||
|
|||||||
Reference in New Issue
Block a user