We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent c7c264b commit a7b3cb7Copy full SHA for a7b3cb7
bases/bot_detector/worker_hiscore/core.py
@@ -20,8 +20,8 @@
20
21
class Settings(BaseSettings):
22
N_WORKERS: int = 1
23
- MAX_BATCH_SIZE: int = 10_000 # TODO: env variable?
24
- MAX_INTERVAL_MS: int = 1_000 # TODO: env variable?
+ MAX_BATCH_SIZE: int = 10_000
+ MAX_INTERVAL_MS: int = 5_000
25
26
27
async def insert_batch(
@@ -70,7 +70,7 @@ async def consume_many_task(
70
max_messages=max_messages,
71
timeout_ms=max_interval_ms,
72
)
73
- logger.debug(f"[{worker_id}] consumed {len(batch)} scrapes")
+ logger.info(f"[{worker_id}] consumed {len(batch)} scrapes")
74
75
if errors:
76
logger.error(f"[{worker_id}] Errors during consumption: {errors}")
0 commit comments