diff --git a/services/selfmon/collectors/liftbridge.py b/services/selfmon/collectors/liftbridge.py index 62e018c1d52c1405cbd25d251cc550156456e18e..d5c4a7c646fef882878aa5567d865ac008b4bcf9 100644 --- a/services/selfmon/collectors/liftbridge.py +++ b/services/selfmon/collectors/liftbridge.py @@ -23,6 +23,7 @@ class LiftbridgeStreamCollector(BaseCollector): "dispose": "correlator", "mx": "mx", "kafkasender": "kafkasender", + "jobs": "worker", } async def get_meta(self) -> Metadata: