(
response, callback_manager, background, cache_key=None
)
| 467 | |
| 468 | |
| 469 | def _progress_background_callback( |
| 470 | response, callback_manager, background, cache_key=None |
| 471 | ): |
| 472 | progress_outputs = background.get("progress") |
| 473 | if cache_key is None: |
| 474 | adapter = get_app().backend.request_adapter() |
| 475 | cache_key = adapter.args.get("cacheKey") |
| 476 | |
| 477 | if progress_outputs: |
| 478 | # Get the progress before the result as it would be erased after the results. |
| 479 | progress = callback_manager.get_progress(cache_key) |
| 480 | if progress: |
| 481 | response["progress"] = { |
| 482 | str(x): progress[i] for i, x in enumerate(progress_outputs) |
| 483 | } |
| 484 | |
| 485 | |
| 486 | def _update_background_callback( |
no test coverage detected
searching dependent graphs…