deepcopy all event

Meituan-Dianping · May 20, 2024 · 5ae8f10 · 5ae8f10
1 parent 6359b6a
commit 5ae8f10
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/lyrebird/db/database_server.py b/lyrebird/db/database_server.py
@@ -133,8 +133,9 @@ def _fk_pragma_on_connect(self, dbapi_con, con_record):
     def event_receiver(self, event, channel=None, event_id=None):
         # event is decoded , which should be encoded when save
         # deepcopy to avoid affecting checker running
+        event = copy.deepcopy(event)
         if channel == 'flow':
-            application.encoders_decoders.encoder_handler(copy.deepcopy(event['flow']))
+            application.encoders_decoders.encoder_handler(event['flow'])
 
         content = json.dumps(event, ensure_ascii=False)
         if isinstance(event, dict):