fix(enrich): unwantedly replacing data (#209)

* fix(enrich): unwantedly replacing data

* refactor(bigquery): add more information when logging

plugins/extractors/bigquery/bigquery.go

@@ -88,15 +88,15 @@ func (e *Extractor) Extract(ctx context.Context, config map[string]interface{},
 		return
 	}
 
-	// Fetch and iterate over datesets
+	// Fetch and iterate over datasets
 	it := e.client.Datasets(ctx)
 	for {
 		ds, err := it.Next()
 		if err == iterator.Done {
 			break
 		}
 		if err != nil {
-			return errors.Wrap(err, "failed to fetch dataset")
+			return errors.Wrapf(err, "failed to fetch dataset %s", ds.DatasetID)
 		}
 		e.extractTable(ctx, ds, out)
 	}
@@ -123,12 +123,12 @@ func (e *Extractor) extractTable(ctx context.Context, ds *bigquery.Dataset, out
 			break
 		}
 		if err != nil {
-			e.logger.Error("failed to scan, skipping table", "err", err)
+			e.logger.Error("failed to scan, skipping table", "err", err, "table", table.FullyQualifiedName())
 			continue
 		}
 		tmd, err := table.Metadata(ctx)
 		if err != nil {
-			e.logger.Error("failed to fetch table's metadata, skipping table", "err", err)
+			e.logger.Error("failed to fetch table's metadata, skipping table", "err", err, "table", table.FullyQualifiedName())
 			continue
 		}
 

utils/custom_properties.go

@@ -41,15 +41,15 @@ func SetCustomProperties(data interface{}, customFields map[string]interface{})
 	case assets.Table:
 		data.Properties = createOrGetCustomFacet(data.Properties)
 		data.Properties.Attributes = protoStruct
-		res = data.Properties
+		res = data
 	case assets.Topic:
 		data.Properties = createOrGetCustomFacet(data.Properties)
 		data.Properties.Attributes = protoStruct
-		res = data.Properties
+		res = data
 	case assets.Dashboard:
 		data.Properties = createOrGetCustomFacet(data.Properties)
 		data.Properties.Attributes = protoStruct
-		res = data.Properties
+		res = data
 	default:
 		res = data
 	}