Reset the entire pipeline.
(self)
| 245 | return status |
| 246 | |
| 247 | def reset_pipeline(self): |
| 248 | """Reset the entire pipeline.""" |
| 249 | self.results.clear() |
| 250 | if self.status_file.exists(): |
| 251 | self.status_file.unlink() |
| 252 | print("Pipeline reset successfully") |
| 253 | |
| 254 | def print_status(self): |
| 255 | """Print current pipeline status.""" |