Returns the int value of event processor metric from the /events catalogd debug page
(metric_key, default_val=None)
| 141 | |
| 142 | @staticmethod |
| 143 | def get_int_metric(metric_key, default_val=None): |
| 144 | """Returns the int value of event processor metric from the /events catalogd debug |
| 145 | page""" |
| 146 | metrics = EventProcessorUtils.get_event_processor_metrics() |
| 147 | if metric_key not in metrics: |
| 148 | return int(default_val) |
| 149 | return int(metrics[metric_key]) |
| 150 | |
| 151 | @staticmethod |
| 152 | def get_last_synced_event_id(): |