in services/ui_backend_service/api/heartbeat_monitor.py [0:0]
def __init__(self, event_emitter=None, db=None, cache=None):
# Init the abstract class
super().__init__(
event_name="task-heartbeat",
db=db,
event_emitter=event_emitter,
cache=cache
)
# Table for data fetching for load_and_broadcast and add_to_watch
self._task_table = self.db.task_table_postgres
self._run_table = self.db.run_table_postgres
self.refiner = TaskRefiner(cache=self.cache.artifact_cache) if cache else None