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 bf5c890 commit 5d06b25Copy full SHA for 5d06b25
src/workflows/recipe/__init__.py
@@ -1,6 +1,7 @@
1
from __future__ import annotations
2
3
import functools
4
+import logging
5
from collections.abc import Callable
6
from typing import Any
7
@@ -16,6 +17,8 @@
16
17
"wrap_subscribe_broadcast",
18
]
19
20
+logger = logging.getLogger("workflows.recipe")
21
+
22
23
def _wrap_subscription(
24
transport_layer,
@@ -76,6 +79,10 @@ def unwrap_recipe(header, message):
76
79
# "First 1000 characters of header:\n%s\n" + \
77
80
# "First 1000 characters of message:\n%s",
78
81
# str(header)[:1000], str(message)[:1000])
82
+ logger.error(
83
+ "The input to this service is not a wrapped recipe. "
84
+ "Unable to process incoming message."
85
+ )
86
transport_layer.nack(header)
87
88
if mangle_for_receiving:
0 commit comments