diff --git a/src/langbot/pkg/platform/sources/lark.py b/src/langbot/pkg/platform/sources/lark.py
index 7ed0b8c9..955c583b 100644
--- a/src/langbot/pkg/platform/sources/lark.py
+++ b/src/langbot/pkg/platform/sources/lark.py
@@ -940,7 +940,10 @@ class LarkAdapter(abstract_platform_adapter.AbstractMessagePlatformAdapter):
                             message_chain=message_chain,
                             adapter=self,
                             pipeline_uuid=pipeline_uuid,
-                            variables={'_dify_form_action': form_action_data},
+                            variables={
+                                '_dify_form_action': form_action_data,
+                                '_routed_by_rule': True,
+                            },
                         )
 
                     schedule_on_app_loop(add_form_action_query())
diff --git a/src/langbot/pkg/platform/sources/telegram.py b/src/langbot/pkg/platform/sources/telegram.py
index c1d9ab68..3c6c9447 100644
--- a/src/langbot/pkg/platform/sources/telegram.py
+++ b/src/langbot/pkg/platform/sources/telegram.py
@@ -309,7 +309,10 @@ class TelegramAdapter(abstract_platform_adapter.AbstractMessagePlatformAdapter):
                         message_chain=message_chain,
                         adapter=self,
                         pipeline_uuid=pipeline_uuid,
-                        variables={'_dify_form_action': form_action_data},
+                        variables={
+                            '_dify_form_action': form_action_data,
+                            '_routed_by_rule': True,
+                        },
                     )
             except Exception:
                 await self.logger.error(f'Error in telegram callback query: {traceback.format_exc()}')