fix metric
This commit is contained in:
parent
fb98a4d7d0
commit
a7e6bcb366
1 changed files with 1 additions and 2 deletions
|
@ -878,8 +878,6 @@ class LBRYElectrumX(asyncio.Protocol):
|
||||||
"""Handle an incoming request. ElectrumX doesn't receive
|
"""Handle an incoming request. ElectrumX doesn't receive
|
||||||
notifications from client sessions.
|
notifications from client sessions.
|
||||||
"""
|
"""
|
||||||
self.session_manager.request_count_metric.labels(method=request.method).inc()
|
|
||||||
|
|
||||||
if isinstance(request, Request):
|
if isinstance(request, Request):
|
||||||
method = request.method
|
method = request.method
|
||||||
if method == 'blockchain.block.get_chunk':
|
if method == 'blockchain.block.get_chunk':
|
||||||
|
@ -958,6 +956,7 @@ class LBRYElectrumX(asyncio.Protocol):
|
||||||
raise RPCError(JSONRPC.METHOD_NOT_FOUND, f'unknown method "{method}"')
|
raise RPCError(JSONRPC.METHOD_NOT_FOUND, f'unknown method "{method}"')
|
||||||
else:
|
else:
|
||||||
raise ValueError
|
raise ValueError
|
||||||
|
self.session_manager.request_count_metric.labels(method=request.method).inc()
|
||||||
if isinstance(request.args, dict):
|
if isinstance(request.args, dict):
|
||||||
return await coro(**request.args)
|
return await coro(**request.args)
|
||||||
return await coro(*request.args)
|
return await coro(*request.args)
|
||||||
|
|
Loading…
Reference in a new issue