()
| 603 | raise HTTPException(status_code=401, detail="Invalid authentication token") |
| 604 | |
| 605 | def run_indexing(): |
| 606 | try: |
| 607 | db.index_all_workflows(force_reindex=force) |
| 608 | print(f"Reindexing completed successfully (requested by {client_ip})") |
| 609 | except Exception as e: |
| 610 | print(f"Error during reindexing: {e}") |
| 611 | |
| 612 | background_tasks.add_task(run_indexing) |
| 613 | return {"message": "Reindexing started in background", "requested_by": client_ip} |
nothing calls this directly
no test coverage detected