fix: The workflow cannot function properly after the conversation flow is disconnected (#2428)

Author: shaohuzhang1

apps/application/flow/workflow_manage.py

@@ -382,6 +382,8 @@ def await_result(self):
                     break
                 yield chunk
         finally:
+            while self.is_run():
+                pass
             details = self.get_runtime_details()
             message_tokens = sum([row.get('message_tokens') for row in details.values() if
                                   'message_tokens' in row and row.get('message_tokens') is not None])

apps/common/middleware/gzip.py

@@ -44,10 +44,10 @@ def process_response(self, request, response):
             if response.is_async:
                 # pull to lexical scope to capture fixed reference in case
                 # streaming_content is set again later.
-                orignal_iterator = response.streaming_content
+                original_iterator = response.streaming_content
 
                 async def gzip_wrapper():
-                    async for chunk in orignal_iterator:
+                    async for chunk in original_iterator:
                         yield compress_string(
                             chunk,
                             max_random_bytes=self.max_random_bytes,