Resolve increased time. (#14074)

src/lightning_app/CHANGELOG.md

@@ -27,3 +27,5 @@ The format is based on [Keep a Changelog](http://keepachangelog.com/en/1.0.0/).
 ### Fixed
 
 - Resolved a bug where the work statuses will grow quickly and be duplicated ([#13970](https://github.com/Lightning-AI/lightning/pull/13970))
+
+- Resolved a bug about a race condition when sending the work state through the caller_queue ([#14074](https://github.com/Lightning-AI/lightning/pull/14074))

src/lightning_app/utilities/proxies.py

@@ -74,7 +74,7 @@ def _send_data_to_caller_queue(work: "LightningWork", caller_queue: "BaseQueue",
 
     data.update({"state": work_state})
     logger.debug(f"Sending to {work.name}: {data}")
-    caller_queue.put(data)
+    caller_queue.put(deepcopy(data))
 
     # Reset the calls entry.
     work_state["calls"] = calls

tests/tests_app/core/test_lightning_app.py

@@ -896,6 +896,7 @@ class SizeWork(LightningWork):
 
     def run(self, signal: int):
         self.counter += 1
+        assert len(self._calls) == 2
 
 
 class SizeFlow(LightningFlow):