(status, run_id=None)
| 219 | |
| 220 | |
| 221 | def log_training_status(status, run_id=None): |
| 222 | if not mlops_enabled(MLOpsStore.mlops_args): |
| 223 | return |
| 224 | |
| 225 | if run_id is not None: |
| 226 | MLOpsStore.mlops_args.run_id = run_id |
| 227 | MLOpsStore.mlops_run_id = run_id |
| 228 | set_realtime_params() |
| 229 | |
| 230 | if not MLOpsStore.mlops_bind_result: |
| 231 | return |
| 232 | |
| 233 | logging.info("log training status {}".format(status)) |
| 234 | |
| 235 | setup_log_mqtt_mgr() |
| 236 | if mlops_parrot_enabled(MLOpsStore.mlops_args): |
| 237 | MLOpsStore.mlops_metrics.broadcast_client_training_status(MLOpsStore.mlops_edge_id, status) |
| 238 | else: |
| 239 | MLOpsStore.mlops_metrics.report_client_training_status(MLOpsStore.mlops_edge_id, status) |
| 240 | |
| 241 | |
| 242 | def log_aggregation_status(status, run_id=None): |
no test coverage detected