File tree Expand file tree Collapse file tree 1 file changed +4
-0
lines changed Expand file tree Collapse file tree 1 file changed +4
-0
lines changed Original file line number Diff line number Diff line change 1818from forge .controller .provisioner import shutdown
1919
2020from forge .data_models .completion import Completion
21+ from forge .observability .metric_actors import get_or_create_metric_logger
2122from omegaconf import DictConfig
2223
2324os .environ ["HYPERACTOR_MESSAGE_DELIVERY_TIMEOUT_SECS" ] = "600"
2425os .environ ["HYPERACTOR_CODE_MAX_FRAME_LENGTH" ] = "1073741824"
2526
2627
2728async def run (cfg : DictConfig ):
29+ metric_logging_cfg = cfg .get ("metric_logging" , {"console" : {"log_per_rank" : False }})
30+ mlogger = await get_or_create_metric_logger ()
31+ await mlogger .init_backends .call_one (metric_logging_cfg )
2832
2933 if (prompt := cfg .get ("prompt" )) is None :
3034 gd = cfg .policy .get ("sampling_config" , {}).get ("guided_decoding" , False )
You can’t perform that action at this time.
0 commit comments