[Bug]: Continue as new Error

[Vedantsahai18]

📜 Description

blob store not working correctly!

{
  "type": "workflowExecutionFailedEventAttributes",
  "failure": {
    "message": "Child Workflow execution failed",
    "cause": {
      "message": "Error in batch 4: Continue as new",
      "stackTrace": "  File \"/app/.venv/lib/python3.12/site-packages/temporalio/worker/_workflow_instance.py\", line 1808, in _run_top_level_workflow_function\n    await coro\n\n  File \"/app/.venv/lib/python3.12/site-packages/temporalio/worker/_workflow_instance.py\", line 857, in run_workflow\n    result = await self._inbound.execute_workflow(input)\n             ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^\n\n  File \"/app/.venv/lib/python3.12/site-packages/temporalio/contrib/opentelemetry.py\", line 356, in execute_workflow\n    return await super().execute_workflow(input)\n           ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^\n\n  File \"/app/.venv/lib/python3.12/site-packages/temporalio/worker/_interceptor.py\", line 328, in execute_workflow\n    return await self.next.execute_workflow(input)\n           ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^\n\n  File \"/app/agents_api/common/interceptors.py\", line 82, in wrapper\n    result = await func(self, input)\n             ^^^^^^^^^^^^^^^^^^^^^^^\n\n  File \"/app/agents_api/common/interceptors.py\", line 154, in execute_workflow\n    return await handle_execution_with_errors(\n           ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^\n\n  File \"/app/agents_api/common/interceptors.py\", line 109, in handle_execution_with_errors\n    return await execution_fn(input)\n           ^^^^^^^^^^^^^^^^^^^^^^^^^\n\n  File \"/app/.venv/lib/python3.12/site-packages/temporalio/worker/_interceptor.py\", line 328, in execute_workflow\n    return await self.next.execute_workflow(input)\n           ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^\n\n  File \"/app/.venv/lib/python3.12/site-packages/temporalio/worker/_workflow_instance.py\", line 2140, in execute_workflow\n    return await input.run_fn(*args)\n           ^^^^^^^^^^^^^^^^^^^^^^^^^\n\n  File \"/app/agents_api/workflows/task_execution/__init__.py\", line 307, in run\n    result = await execute_map_reduce_step_parallel(\n             ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^\n\n  File \"/app/agents_api/workflows/task_execution/helpers.py\", line 310, in execute_map_reduce_step_parallel\n    raise ApplicationError(msg) from e\n",
      "cause": {
        "message": "Continue as new",
        "stackTrace": "  File \"/app/agents_api/workflows/task_execution/helpers.py\", line 292, in execute_map_reduce_step_parallel\n    batch_results = await asyncio.gather(*batch_pending)\n                    ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^\n\n  File \"/app/agents_api/workflows/task_execution/helpers.py\", line 61, in continue_as_child\n    return await run(\n                 ^^^^\n\n  File \"/app/.venv/lib/python3.12/site-packages/temporalio/workflow.py\", line 4219, in continue_as_new\n    _Runtime.current().workflow_continue_as_new(\n\n  File \"/app/.venv/lib/python3.12/site-packages/temporalio/worker/_workflow_instance.py\", line 945, in workflow_continue_as_new\n    self._outbound.continue_as_new(\n\n  File \"/app/.venv/lib/python3.12/site-packages/temporalio/contrib/opentelemetry.py\", line 592, in continue_as_new\n    super().continue_as_new(input)\n\n  File \"/app/.venv/lib/python3.12/site-packages/temporalio/worker/_interceptor.py\", line 364, in continue_as_new\n    self.next.continue_as_new(input)\n\n  File \"/app/.venv/lib/python3.12/site-packages/temporalio/worker/_workflow_instance.py\", line 2191, in continue_as_new\n    self._instance._outbound_continue_as_new(input)\n\n  File \"/app/.venv/lib/python3.12/site-packages/temporalio/worker/_workflow_instance.py\", line 1431, in _outbound_continue_as_new\n    raise _ContinueAsNewError(self, input)\n",
        "applicationFailureInfo": {
          "type": "_ContinueAsNewError"
        }
      },

👟 Reproduction steps

Run the cookbook 04 in the cookbooks directory

👀 Have you searched previous issues to see if this has been raised before?

• I checked and didn't find similar issue