diff --git a/src/app.py b/src/app.py
index 1de0204..a5c40df 100644
--- a/src/app.py
+++ b/src/app.py
@@ -36,7 +36,7 @@ async def on_message(message: IncomingMessage):
     msg_json = json.loads(message.body)
     now = datetime.now(tz=tzlocal.get_localzone())
 
-    r = requests.get(f"http://input-service/sample/{msg_json['tag']}")
+    r = requests.get(f"http://input-service/input/{msg_json['tag']}")
     r.raise_for_status()
 
     fields = {