We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 524ef8c commit 05d362aCopy full SHA for 05d362a
metadata-ingestion/src/datahub/ingestion/source/gc/dataprocess_cleanup.py
@@ -401,7 +401,10 @@ def get_workunits_internal(self) -> Iterable[MetadataWorkUnit]:
401
total_runs=job.get("entity").get("runs").get("total"),
402
)
403
if datajob_entity.total_runs > 0:
404
- self.delete_dpi_from_datajobs(datajob_entity)
+ try:
405
+ self.delete_dpi_from_datajobs(datajob_entity)
406
+ except Exception as e:
407
+ logger.error(f"While trying to delete {datajob_entity} got {e}")
408
if (
409
datajob_entity.total_runs == 0
410
and self.config.delete_empty_data_jobs
0 commit comments