Skip to content

Commit c99618e

Browse files
committed
Nack message if no workflow entry point is found
1 parent 13f52e6 commit c99618e

File tree

1 file changed

+2
-0
lines changed

1 file changed

+2
-0
lines changed

src/murfey/server/__init__.py

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -2948,6 +2948,8 @@ def feedback_callback(header: dict, message: dict) -> None:
29482948
) # Returns either 1 item or empty list
29492949
if not workflows:
29502950
logger.error(f"No workflow found for {sanitise(message['register'])}")
2951+
if _transport_object:
2952+
_transport_object.transport.nack(header, requeue=False)
29512953
return None
29522954
# Run the workflow if a match is found
29532955
workflow: EntryPoint = workflows[0]

0 commit comments

Comments
 (0)