We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 953f2fb commit 632285cCopy full SHA for 632285c
src/murfey/server/__init__.py
@@ -2949,9 +2949,11 @@ def feedback_callback(header: dict, message: dict) -> None:
2949
# Send it directly to DLQ without trying to rerun it
2950
_transport_object.transport.nack(header, requeue=False)
2951
if not result:
2952
- logger.error(f"Workflow {message['register']} returned {result}")
+ logger.error(
2953
+ f"Workflow {sanitise(message['register'])} returned {result}"
2954
+ )
2955
return None
- logger.error(f"No workflow found for {message['register']}")
2956
+ logger.error(f"No workflow found for {sanitise(message['register'])}")
2957
if _transport_object:
2958
2959
0 commit comments