chore: Revert cleanup-stale-data filter change

From #265
cloudquery · May 23, 2022 · 09038e2 · 09038e2
1 parent 1f74be7
commit 09038e2
Showing 1 changed file with 2 additions and 4 deletions.
diff --git a/provider/execution/execution.go b/provider/execution/execution.go
@@ -270,10 +270,8 @@ func (e TableExecutor) callTableResolve(ctx context.Context, client schema.Clien
 		e.Logger.Info("fetched successfully", "count", nc)
 	}
 
-	if !diags.HasErrors() {
-		if err := e.cleanupStaleData(ctx, client, parent); err != nil {
-			return nc, diags.Add(fromError(err, diag.WithType(diag.DATABASE), diag.WithSummary("failed to cleanup stale data on table %q", e.Table.Name)))
-		}
+	if err := e.cleanupStaleData(ctx, client, parent); err != nil {
+		return nc, diags.Add(fromError(err, diag.WithType(diag.DATABASE), diag.WithSummary("failed to cleanup stale data on table %q", e.Table.Name)))
 	}
 
 	return nc, diags