diff --git a/coverage.md b/coverage.md
index a85da853ba..a577fab84d 100644
--- a/coverage.md
+++ b/coverage.md
@@ -529,11 +529,10 @@
 | github.com/cloudquery/plugin-sdk/v4/scheduler/batch.go:130: | work | 66.7% |
 | github.com/cloudquery/plugin-sdk/v4/scheduler/batch.go:173: | process | 87.0% |
 | github.com/cloudquery/plugin-sdk/v4/scheduler/batch.go:215: | close | 100.0% |
-| github.com/cloudquery/plugin-sdk/v4/scheduler/batchsender/batch_sender.go:28: | NewBatchSender | 0.0% |
-| github.com/cloudquery/plugin-sdk/v4/scheduler/batchsender/batch_sender.go:32: | Send | 0.0% |
-| github.com/cloudquery/plugin-sdk/v4/scheduler/batchsender/batch_sender.go:59: | appendToBatch | 0.0% |
-| github.com/cloudquery/plugin-sdk/v4/scheduler/batchsender/batch_sender.go:66: | flush | 0.0% |
-| github.com/cloudquery/plugin-sdk/v4/scheduler/batchsender/batch_sender.go:80: | Close | 0.0% |
+| github.com/cloudquery/plugin-sdk/v4/scheduler/batchsender/batch_sender.go:28: | NewBatchSender | 100.0% |
+| github.com/cloudquery/plugin-sdk/v4/scheduler/batchsender/batch_sender.go:32: | Send | 75.0% |
+| github.com/cloudquery/plugin-sdk/v4/scheduler/batchsender/batch_sender.go:67: | flushLocked | 100.0% |
+| github.com/cloudquery/plugin-sdk/v4/scheduler/batchsender/batch_sender.go:78: | Close | 100.0% |
 | github.com/cloudquery/plugin-sdk/v4/scheduler/metrics/duration.go:15: | Start | 100.0% |
 | github.com/cloudquery/plugin-sdk/v4/scheduler/metrics/duration.go:28: | End | 100.0% |
 | github.com/cloudquery/plugin-sdk/v4/scheduler/metrics/metrics.go:32: | NewMetrics | 100.0% |
@@ -592,10 +591,10 @@
 | github.com/cloudquery/plugin-sdk/v4/scheduler/scheduler.go:301: | shardTableClients | 100.0% |
 | github.com/cloudquery/plugin-sdk/v4/scheduler/scheduler_debug.go:18: | getTestMultiplier | 42.9% |
 | github.com/cloudquery/plugin-sdk/v4/scheduler/scheduler_debug.go:30: | syncTest | 0.0% |
-| github.com/cloudquery/plugin-sdk/v4/scheduler/scheduler_dfs.go:24: | syncDfs | 86.7% |
+| github.com/cloudquery/plugin-sdk/v4/scheduler/scheduler_dfs.go:24: | syncDfs | 93.3% |
 | github.com/cloudquery/plugin-sdk/v4/scheduler/scheduler_dfs.go:81: | resolveTableDfs | 87.2% |
 | github.com/cloudquery/plugin-sdk/v4/scheduler/scheduler_dfs.go:154: | resolveResourcesDfs | 69.6% |
-| github.com/cloudquery/plugin-sdk/v4/scheduler/scheduler_round_robin.go:15: | syncRoundRobin | 85.2% |
+| github.com/cloudquery/plugin-sdk/v4/scheduler/scheduler_round_robin.go:15: | syncRoundRobin | 92.6% |
 | github.com/cloudquery/plugin-sdk/v4/scheduler/scheduler_round_robin.go:69: | roundRobinInterleave | 100.0% |
 | github.com/cloudquery/plugin-sdk/v4/scheduler/scheduler_shuffle.go:13: | syncShuffle | 87.1% |
 | github.com/cloudquery/plugin-sdk/v4/scheduler/scheduler_shuffle.go:75: | hashTableNames | 100.0% |
@@ -670,25 +669,25 @@
 | github.com/cloudquery/plugin-sdk/v4/schema/table.go:444: | FlattenTables | 100.0% |
 | github.com/cloudquery/plugin-sdk/v4/schema/table.go:461: | UnflattenTables | 93.3% |
 | github.com/cloudquery/plugin-sdk/v4/schema/table.go:484: | TableNames | 100.0% |
-| github.com/cloudquery/plugin-sdk/v4/schema/table.go:493: | GetTopLevel | 0.0% |
-| github.com/cloudquery/plugin-sdk/v4/schema/table.go:503: | Get | 42.9% |
-| github.com/cloudquery/plugin-sdk/v4/schema/table.go:516: | ValidateDuplicateColumns | 0.0% |
-| github.com/cloudquery/plugin-sdk/v4/schema/table.go:525: | ValidateDuplicateTables | 85.7% |
-| github.com/cloudquery/plugin-sdk/v4/schema/table.go:537: | GetPaidTables | 0.0% |
-| github.com/cloudquery/plugin-sdk/v4/schema/table.go:548: | HasPaidTables | 0.0% |
-| github.com/cloudquery/plugin-sdk/v4/schema/table.go:553: | filterDfs | 100.0% |
-| github.com/cloudquery/plugin-sdk/v4/schema/table.go:577: | PrimaryKeysIndexes | 0.0% |
-| github.com/cloudquery/plugin-sdk/v4/schema/table.go:588: | ToArrowSchema | 93.8% |
-| github.com/cloudquery/plugin-sdk/v4/schema/table.go:619: | GetChanges | 100.0% |
-| github.com/cloudquery/plugin-sdk/v4/schema/table.go:673: | ValidateDuplicateColumns | 0.0% |
-| github.com/cloudquery/plugin-sdk/v4/schema/table.go:689: | Column | 0.0% |
-| github.com/cloudquery/plugin-sdk/v4/schema/table.go:701: | OverwriteOrAddColumn | 0.0% |
-| github.com/cloudquery/plugin-sdk/v4/schema/table.go:711: | PrimaryKeys | 100.0% |
-| github.com/cloudquery/plugin-sdk/v4/schema/table.go:722: | IncrementalKeys | 0.0% |
-| github.com/cloudquery/plugin-sdk/v4/schema/table.go:733: | PrimaryKeyComponents | 0.0% |
-| github.com/cloudquery/plugin-sdk/v4/schema/table.go:744: | TableNames | 100.0% |
-| github.com/cloudquery/plugin-sdk/v4/schema/table.go:752: | Copy | 100.0% |
-| github.com/cloudquery/plugin-sdk/v4/schema/table.go:764: | ValidColumnName | 0.0% |
+| github.com/cloudquery/plugin-sdk/v4/schema/table.go:494: | GetTopLevel | 0.0% |
+| github.com/cloudquery/plugin-sdk/v4/schema/table.go:504: | Get | 42.9% |
+| github.com/cloudquery/plugin-sdk/v4/schema/table.go:517: | ValidateDuplicateColumns | 0.0% |
+| github.com/cloudquery/plugin-sdk/v4/schema/table.go:526: | ValidateDuplicateTables | 85.7% |
+| github.com/cloudquery/plugin-sdk/v4/schema/table.go:538: | GetPaidTables | 0.0% |
+| github.com/cloudquery/plugin-sdk/v4/schema/table.go:549: | HasPaidTables | 0.0% |
+| github.com/cloudquery/plugin-sdk/v4/schema/table.go:554: | filterDfs | 100.0% |
+| github.com/cloudquery/plugin-sdk/v4/schema/table.go:578: | PrimaryKeysIndexes | 0.0% |
+| github.com/cloudquery/plugin-sdk/v4/schema/table.go:589: | ToArrowSchema | 93.8% |
+| github.com/cloudquery/plugin-sdk/v4/schema/table.go:620: | GetChanges | 100.0% |
+| github.com/cloudquery/plugin-sdk/v4/schema/table.go:674: | ValidateDuplicateColumns | 0.0% |
+| github.com/cloudquery/plugin-sdk/v4/schema/table.go:690: | Column | 0.0% |
+| github.com/cloudquery/plugin-sdk/v4/schema/table.go:702: | OverwriteOrAddColumn | 0.0% |
+| github.com/cloudquery/plugin-sdk/v4/schema/table.go:712: | PrimaryKeys | 100.0% |
+| github.com/cloudquery/plugin-sdk/v4/schema/table.go:723: | IncrementalKeys | 0.0% |
+| github.com/cloudquery/plugin-sdk/v4/schema/table.go:734: | PrimaryKeyComponents | 0.0% |
+| github.com/cloudquery/plugin-sdk/v4/schema/table.go:745: | TableNames | 100.0% |
+| github.com/cloudquery/plugin-sdk/v4/schema/table.go:754: | Copy | 100.0% |
+| github.com/cloudquery/plugin-sdk/v4/schema/table.go:766: | ValidColumnName | 0.0% |
 | github.com/cloudquery/plugin-sdk/v4/schema/testdata.go:35: | listOfColumns | 100.0% |
 | github.com/cloudquery/plugin-sdk/v4/schema/testdata.go:45: | mapOfColumns | 100.0% |
 | github.com/cloudquery/plugin-sdk/v4/schema/testdata.go:56: | columnsToFields | 100.0% |
@@ -720,18 +719,18 @@
 | github.com/cloudquery/plugin-sdk/v4/serve/opentelemetry.go:245: | otellogSeverity | 0.0% |
 | github.com/cloudquery/plugin-sdk/v4/serve/opentelemetry.go:266: | newOTELLoggerHook | 0.0% |
 | github.com/cloudquery/plugin-sdk/v4/serve/package.go:55: | writeTablesJSON | 87.1% |
-| github.com/cloudquery/plugin-sdk/v4/serve/package.go:121: | build | 74.0% |
-| github.com/cloudquery/plugin-sdk/v4/serve/package.go:197: | calcChecksum | 75.0% |
-| github.com/cloudquery/plugin-sdk/v4/serve/package.go:211: | getModuleName | 77.8% |
-| github.com/cloudquery/plugin-sdk/v4/serve/package.go:225: | writePackageJSON | 90.0% |
-| github.com/cloudquery/plugin-sdk/v4/serve/package.go:249: | writeSpecJSONSchema | 66.7% |
-| github.com/cloudquery/plugin-sdk/v4/serve/package.go:257: | copyDocs | 75.0% |
-| github.com/cloudquery/plugin-sdk/v4/serve/package.go:282: | versionRegex | 100.0% |
-| github.com/cloudquery/plugin-sdk/v4/serve/package.go:286: | validatePluginExports | 76.3% |
-| github.com/cloudquery/plugin-sdk/v4/serve/package.go:346: | copyFile | 75.0% |
-| github.com/cloudquery/plugin-sdk/v4/serve/package.go:364: | containsRegex | 100.0% |
-| github.com/cloudquery/plugin-sdk/v4/serve/package.go:374: | newCmdPluginPackage | 73.6% |
-| github.com/cloudquery/plugin-sdk/v4/serve/package.go:462: | normalizeMessage | 100.0% |
+| github.com/cloudquery/plugin-sdk/v4/serve/package.go:121: | build | 72.9% |
+| github.com/cloudquery/plugin-sdk/v4/serve/package.go:195: | calcChecksum | 75.0% |
+| github.com/cloudquery/plugin-sdk/v4/serve/package.go:209: | getModuleName | 77.8% |
+| github.com/cloudquery/plugin-sdk/v4/serve/package.go:223: | writePackageJSON | 90.0% |
+| github.com/cloudquery/plugin-sdk/v4/serve/package.go:247: | writeSpecJSONSchema | 66.7% |
+| github.com/cloudquery/plugin-sdk/v4/serve/package.go:255: | copyDocs | 75.0% |
+| github.com/cloudquery/plugin-sdk/v4/serve/package.go:280: | versionRegex | 100.0% |
+| github.com/cloudquery/plugin-sdk/v4/serve/package.go:284: | validatePluginExports | 76.3% |
+| github.com/cloudquery/plugin-sdk/v4/serve/package.go:344: | copyFile | 75.0% |
+| github.com/cloudquery/plugin-sdk/v4/serve/package.go:362: | containsRegex | 100.0% |
+| github.com/cloudquery/plugin-sdk/v4/serve/package.go:372: | newCmdPluginPackage | 73.6% |
+| github.com/cloudquery/plugin-sdk/v4/serve/package.go:460: | normalizeMessage | 100.0% |
 | github.com/cloudquery/plugin-sdk/v4/serve/plugin.go:51: | WithPluginSentryDSN | 0.0% |
 | github.com/cloudquery/plugin-sdk/v4/serve/plugin.go:59: | WithDestinationV0V1Server | 100.0% |
 | github.com/cloudquery/plugin-sdk/v4/serve/plugin.go:66: | WithArgs | 100.0% |
@@ -933,4 +932,4 @@
 | github.com/cloudquery/plugin-sdk/v4/writers/ticker.go:32: | Stop | 0.0% |
 | github.com/cloudquery/plugin-sdk/v4/writers/ticker.go:34: | Reset | 0.0% |
 | github.com/cloudquery/plugin-sdk/v4/writers/ticker.go:36: | Chan | 0.0% |
-| total: | (statements) | 54.8% |
+| total: | (statements) | 55.2% |