| 352 | return d |
| 353 | |
| 354 | def asstr(self, verbosity: int = 0) -> str: |
| 355 | msg = f"Pipeline {self.pipeline.pipeline_name} load step completed in " |
| 356 | if self.started_at: |
| 357 | elapsed = self.finished_at - self.started_at |
| 358 | msg += humanize.precisedelta(elapsed) |
| 359 | else: |
| 360 | msg += "---" |
| 361 | msg += ( |
| 362 | f"\n{len(self.loads_ids)} load package(s) were loaded to destination" |
| 363 | f" {self.destination_name} and into dataset {self.dataset_name}\n" |
| 364 | ) |
| 365 | if self.staging_name: |
| 366 | msg += ( |
| 367 | f"The {self.staging_name} staging destination used" |
| 368 | f" {self.staging_displayable_credentials} location to stage data\n" |
| 369 | ) |
| 370 | |
| 371 | msg += ( |
| 372 | f"The {self.destination_name} destination used" |
| 373 | f" {self.destination_displayable_credentials} location to store data" |
| 374 | ) |
| 375 | msg += self._load_packages_asstr(self.load_packages, verbosity) |
| 376 | |
| 377 | return msg |
| 378 | |
| 379 | @property |
| 380 | def has_failed_jobs(self) -> bool: |