(message: Optional[str], completed: Optional[int] = None)
| 215 | task_id = progress.add_task("[blue]Converting layers...", total=total_blocks, status="Starting") |
| 216 | |
| 217 | def update_status(message: Optional[str], completed: Optional[int] = None) -> None: |
| 218 | if use_rich_progress: |
| 219 | if message is not None: |
| 220 | progress.update(task_id, status=message) |
| 221 | if completed is not None: |
| 222 | progress.update(task_id, completed=completed) |
| 223 | elif rank == 0 and completed and completed % 10 == 0: |
| 224 | log.info(f"Rank {rank}: {completed}/{total_blocks} blocks completed") |
| 225 | |
| 226 | return progress, log_status, update_status |
no outgoing calls
no test coverage detected