@@ -270,7 +270,9 @@ def read_async(fd):
270270 'profile_name' : self .params .get ('profile_name' ),
271271 'cmd' : self .params ['cmd' ][1 ],
272272 }
273- self .app .backup_log_event .emit (f'{ parsed ["levelname" ]} : { parsed ["message" ]} ' , context )
273+ self .app .backup_log_event .emit (
274+ f'[{ self .params ["profile_name" ]} ] { parsed ["levelname" ]} : { parsed ["message" ]} ' , context
275+ )
274276 level_int = getattr (logging , parsed ["levelname" ])
275277 logger .log (level_int , parsed ["message" ])
276278
@@ -279,21 +281,23 @@ def read_async(fd):
279281 error_messages .append ((level_int , parsed ["message" ]))
280282
281283 elif parsed ['type' ] == 'file_status' :
282- self .app .backup_log_event .emit (f'{ parsed ["path" ]} ({ parsed ["status" ]} )' , {})
284+ self .app .backup_log_event .emit (
285+ f'[{ self .params ["profile_name" ]} ] { parsed ["path" ]} ({ parsed ["status" ]} )' , {}
286+ )
283287 elif parsed ['type' ] == 'progress_percent' and parsed .get ("message" ):
284- self .app .backup_log_event .emit (f'{ parsed ["message" ]} ' , {})
288+ self .app .backup_log_event .emit (f'[ { self . params [ "profile_name" ] } ] { parsed ["message" ]} ' , {})
285289 elif parsed ['type' ] == 'archive_progress' and not parsed .get ('finished' , False ):
286290 msg = (
287291 f"{ translate ('BorgJob' ,'Files' )} : { parsed ['nfiles' ]} , "
288292 f"{ translate ('BorgJob' ,'Original' )} : { pretty_bytes (parsed ['original_size' ])} , "
289293 # f"{translate('BorgJob','Compressed')}: {pretty_bytes(parsed['compressed_size'])}, "
290294 f"{ translate ('BorgJob' ,'Deduplicated' )} : { pretty_bytes (parsed ['deduplicated_size' ])} " # noqa: E501
291295 )
292- self .app .backup_progress_event .emit (msg )
296+ self .app .backup_progress_event .emit (f"[ { self . params [ 'profile_name' ] } ] { msg } " )
293297 except json .decoder .JSONDecodeError :
294298 msg = line .strip ()
295299 if msg : # Log only if there is something to log.
296- self .app .backup_log_event .emit (msg , {})
300+ self .app .backup_log_event .emit (f'[ { self . params [ "profile_name" ] } ] { msg } ' , {})
297301 logger .warning (msg )
298302
299303 if p .poll () is not None :
0 commit comments