move to report itself

datahub-project · Dec 13, 2024 · 16811eb · 16811eb
1 parent 28cffe3
commit 16811eb
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/metadata-ingestion/src/datahub/ingestion/source/gc/datahub_gc.py b/metadata-ingestion/src/datahub/ingestion/source/gc/datahub_gc.py
@@ -97,6 +97,7 @@ class DataHubGcSourceReport(
 ):
     expired_tokens_revoked: int = 0
     cleanup_metrics: Dict[str, CleanupOperationMetrics] = field(default_factory=dict)
+    event_not_produced_warn: bool = False
 
     def record_success(self, operation_name: str, timing: float) -> None:
         self.cleanup_metrics[operation_name] = CleanupOperationMetrics(
@@ -135,7 +136,6 @@ def __init__(self, ctx: PipelineContext, config: DataHubGcSourceConfig):
         self.ctx = ctx
         self.config = config
         self.report = DataHubGcSourceReport()
-        self.report.event_not_produced_warn = False
         self.graph = ctx.require_graph("The DataHubGc source")
         self.dataprocess_cleanup = DataProcessCleanup(
             ctx, self.config.dataprocess_cleanup, self.report, self.config.dry_run