Skip to content

Commit

Permalink
disable kafka highscores
Browse files Browse the repository at this point in the history
  • Loading branch information
extreme4all authored Nov 23, 2023
1 parent d97f580 commit 0f49f7e
Showing 1 changed file with 6 additions and 6 deletions.
12 changes: 6 additions & 6 deletions src/core/server.py
Original file line number Diff line number Diff line change
Expand Up @@ -98,9 +98,9 @@ async def validation_exception_handler(request: Request, exc: RequestValidationE
return JSONResponse(content={"detail": error}, status_code=422)


@app.on_event("startup")
async def startup_event():
if config.env != "DEV":
logger.info("startup initiated")
highscore_processor = HighscoreProcessor(batch_size=100)
asyncio.ensure_future(highscore_processor.start())
# @app.on_event("startup")
# async def startup_event():
# if config.env != "DEV":
# logger.info("startup initiated")
# highscore_processor = HighscoreProcessor(batch_size=100)
# asyncio.ensure_future(highscore_processor.start())

0 comments on commit 0f49f7e

Please sign in to comment.