(images, i, *args)
| 297 | return partial_images |
| 298 | |
| 299 | def on_image_step(images, i, *args): |
| 300 | nonlocal last_callback_time |
| 301 | |
| 302 | step_time = time.time() - last_callback_time if last_callback_time != -1 else -1 |
| 303 | last_callback_time = time.time() |
| 304 | |
| 305 | progress = {"step": i, "step_time": step_time, "total_steps": n_steps} |
| 306 | |
| 307 | if images is not None: |
| 308 | progress["output"] = update_temp_img(images, task_temp_images) |
| 309 | |
| 310 | data_queue.put(json.dumps(progress)) |
| 311 | |
| 312 | step_callback() |
| 313 | |
| 314 | return on_image_step |
nothing calls this directly
no test coverage detected