(event_name, event_started=True, event_value=None, event_edge_id=None)
| 151 | |
| 152 | |
| 153 | def event(event_name, event_started=True, event_value=None, event_edge_id=None): |
| 154 | if not mlops_enabled(MLOpsStore.mlops_args): |
| 155 | return |
| 156 | |
| 157 | set_realtime_params() |
| 158 | |
| 159 | if not MLOpsStore.mlops_bind_result: |
| 160 | return |
| 161 | |
| 162 | setup_log_mqtt_mgr() |
| 163 | |
| 164 | if event_started: |
| 165 | MLOpsStore.mlops_event.log_event_started(event_name, event_value, event_edge_id) |
| 166 | else: |
| 167 | MLOpsStore.mlops_event.log_event_ended(event_name, event_value, event_edge_id) |
| 168 | |
| 169 | |
| 170 | def log(metrics: dict, step: int = None, customized_step_key: str = None, commit: bool = True): |
nothing calls this directly
no test coverage detected