tangled
alpha
login
or
join now
hailey.at
/
followgraph
0
fork
atom
this repo has no description
0
fork
atom
overview
issues
pulls
pipelines
fix broken metrics
hailey.at
2 months ago
f28f6a70
2b039f02
+2
-2
2 changed files
expand all
collapse all
unified
split
indexer.py
metrics.py
+1
-1
indexer.py
···
253
253
except Exception as e:
254
254
logger.error(f"Failed to handle event: {e}")
255
255
finally:
256
256
-
prom_metrics.events_handled.labels(kind=kind, status=status)
256
256
+
prom_metrics.events_handled.labels(kind=kind, status=status).inc()
257
257
258
258
async def run(self):
259
259
self.consumer = AIOKafkaConsumer(
+1
-1
metrics.py
···
34
34
)
35
35
36
36
self.insert_duration = Histogram(
37
37
-
name="embedding_duration_seconds",
37
37
+
name="insert_duration_seconds",
38
38
namespace=NAMESPACE,
39
39
buckets=(
40
40
0.001,