Skip to content
This repository was archived by the owner on Jun 8, 2023. It is now read-only.

Commit 07cca97

Browse files
committed
added number of cores to the info status #release-note
1 parent 7e597a8 commit 07cca97

File tree

1 file changed

+2
-0
lines changed

1 file changed

+2
-0
lines changed

pq/server/consumer.py

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1,5 +1,6 @@
11
import time
22
import asyncio
3+
from multiprocessing import cpu_count
34

45
from .producer import Producer
56

@@ -28,6 +29,7 @@ async def worker_tick(self, worker):
2829
info['worker'] = worker.aid
2930
info['node'] = self.node_name
3031
info['pubsub'] = self.pubsub.store.dns
32+
info['cores'] = cpu_count()
3133
info['message-broker'] = self.broker.store.dns
3234
info['time'] = time.time()
3335
if self.cfg.debug:

0 commit comments

Comments
 (0)