fix: Skip relations when initializing metrics (#469)

erezrokah · web-flow · commit 5efe56493a21 · 2022-12-07T08:51:47.000Z
Follow up on #467 (comment) ---
diff --git a/plugins/source_scheduler_dfs.go b/plugins/source_scheduler_dfs.go
@@ -37,6 +37,10 @@ func (p *SourcePlugin) syncDfs(ctx context.Context, spec specs.Source, client sc
 	p.resourceSem = semaphore.NewWeighted(int64(resourceConcurrency))
 
 	for _, table := range tables {
+		if table.Parent != nil {
+			// skip descendent tables here - they are handled in initWithClients
+			continue
+		}
 		clients := []schema.ClientMeta{client}
 		if table.Multiplex != nil {
 			clients = table.Multiplex(client)
