(ctx: _ForwardContext)
| 429 | |
| 430 | |
| 431 | def _build_forward_cancelled_result(ctx: _ForwardContext) -> Dict[str, Any]: |
| 432 | return { |
| 433 | 'task_id': ctx.task_id, |
| 434 | 'source': ctx.source, |
| 435 | 'index_name': ctx.index_name, |
| 436 | 'original_filename': ctx.original_filename, |
| 437 | 'chunks_stored': 0, |
| 438 | 'storage_time': 0, |
| 439 | 'es_result': { |
| 440 | "success": False, |
| 441 | "message": "Indexing cancelled because document was deleted.", |
| 442 | "total_indexed": 0, |
| 443 | "total_submitted": 0, |
| 444 | }, |
| 445 | } |
| 446 | |
| 447 | |
| 448 | def _load_forward_chunks( |