@@ -215,14 +215,14 @@ def async_job_submit(api_helper, node_id, job_callback):
215
215
log_txt_url = _upload_log (log_parser , job_node , storage )
216
216
if log_txt_url :
217
217
job_node ['artifacts' ]['lava_log' ] = log_txt_url
218
- print (f"Log uploaded to { log_txt_url } " )
218
+ logging . info (f"Log uploaded to { log_txt_url } " )
219
219
else :
220
- print ("Failed to upload log" )
220
+ logging . info ("Failed to upload log" )
221
221
metrics .add ('lava_callback_late_fail_total' , 1 )
222
222
callback_json_url = _upload_callback_data (callback_data , job_node , storage )
223
223
if callback_json_url :
224
224
job_node ['artifacts' ]['callback_data' ] = callback_json_url
225
- print (f"Callback data uploaded to { callback_json_url } " )
225
+ logging . info (f"Callback data uploaded to { callback_json_url } " )
226
226
else :
227
227
metrics .add ('lava_callback_late_fail_total' , 1 )
228
228
# failed LAVA job should have result set to 'incomplete'
@@ -238,10 +238,10 @@ def async_job_submit(api_helper, node_id, job_callback):
238
238
if result .startswith ("artifact-upload:" ):
239
239
artifact = result .split (':' , 2 )
240
240
if len (artifact ) != 3 :
241
- print (f"Failed to extract artifact name and URL from { result } " )
241
+ logging . info (f"Failed to extract artifact name and URL from { result } " )
242
242
continue
243
243
job_node ['artifacts' ][artifact [1 ]] = artifact [2 ]
244
- print (f"Artifact { artifact [1 ]} added with URL { artifact [2 ]} " )
244
+ logging . info (f"Artifact { artifact [1 ]} added with URL { artifact [2 ]} " )
245
245
hierarchy = job_callback .get_hierarchy (results , job_node )
246
246
api_helper .submit_results (hierarchy , job_node )
247
247
0 commit comments