| """Entry point for allocation worker.""" | |
| import asyncio | |
| import os | |
| if os.getenv("DEBUG_WORKER") == "allocation": | |
| import debugpy | |
| debugpy.listen(("0.0.0.0", 5678)) | |
| print("[debugpy] allocation worker listening on port 5678...") | |
| if os.getenv("DEBUGPY_WAIT") == "1": | |
| debugpy.wait_for_client() | |
| from app.workers.allocation_worker import main | |
| if __name__ == "__main__": | |
| asyncio.run(main()) | |