diff --git a/coverage.md b/coverage.md
index 074c458670..1bfd2f6d72 100644
--- a/coverage.md
+++ b/coverage.md
@@ -85,12 +85,46 @@
 | github.com/cloudquery/plugin-sdk/v4/internal/batch/slice.go:127: | newSlicedRecord | 80.0% |
 | github.com/cloudquery/plugin-sdk/v4/internal/batch/slice.go:145: | SliceRecord | 100.0% |
 | github.com/cloudquery/plugin-sdk/v4/internal/batch/slice.go:150: | SplitRecord | 100.0% |
-| github.com/cloudquery/plugin-sdk/v4/internal/clients/state/v3/state.go:39: | NewClient | 0.0% |
-| github.com/cloudquery/plugin-sdk/v4/internal/clients/state/v3/state.go:134: | SetKey | 0.0% |
-| github.com/cloudquery/plugin-sdk/v4/internal/clients/state/v3/state.go:149: | Flush | 0.0% |
-| github.com/cloudquery/plugin-sdk/v4/internal/clients/state/v3/state.go:192: | GetKey | 0.0% |
-| github.com/cloudquery/plugin-sdk/v4/internal/clients/state/v3/state.go:198: | Close | 0.0% |
-| github.com/cloudquery/plugin-sdk/v4/internal/clients/state/v3/state.go:205: | Table | 0.0% |
+| github.com/cloudquery/plugin-sdk/v4/internal/checkpoint/checkpoint.go:40: | WithScope | 0.0% |
+| github.com/cloudquery/plugin-sdk/v4/internal/checkpoint/checkpoint.go:45: | FromContext | 0.0% |
+| github.com/cloudquery/plugin-sdk/v4/internal/checkpoint/checkpoint.go:51: | Deliver | 63.6% |
+| github.com/cloudquery/plugin-sdk/v4/internal/checkpoint/checkpoint.go:76: | Drop | 66.7% |
+| github.com/cloudquery/plugin-sdk/v4/internal/checkpoint/checkpoint.go:91: | GetTable | 0.0% |
+| github.com/cloudquery/plugin-sdk/v4/internal/checkpoint/checkpoint.go:92: | IsSyncMessage | 0.0% |
+| github.com/cloudquery/plugin-sdk/v4/internal/checkpoint/checkpoint.go:100: | GetTable | 0.0% |
+| github.com/cloudquery/plugin-sdk/v4/internal/checkpoint/checkpoint.go:101: | IsSyncMessage | 0.0% |
+| github.com/cloudquery/plugin-sdk/v4/internal/checkpoint/checkpoint.go:118: | NewHeld | 100.0% |
+| github.com/cloudquery/plugin-sdk/v4/internal/checkpoint/checkpoint.go:123: | root | 100.0% |
+| github.com/cloudquery/plugin-sdk/v4/internal/checkpoint/checkpoint.go:137: | lockRoot | 100.0% |
+| github.com/cloudquery/plugin-sdk/v4/internal/checkpoint/checkpoint.go:149: | Delivered | 100.0% |
+| github.com/cloudquery/plugin-sdk/v4/internal/checkpoint/checkpoint.go:156: | Aborted | 100.0% |
+| github.com/cloudquery/plugin-sdk/v4/internal/checkpoint/checkpoint.go:162: | holder | 0.0% |
+| github.com/cloudquery/plugin-sdk/v4/internal/checkpoint/checkpoint.go:169: | NotifyAbort | 100.0% |
+| github.com/cloudquery/plugin-sdk/v4/internal/checkpoint/checkpoint.go:183: | MergedInto | 0.0% |
+| github.com/cloudquery/plugin-sdk/v4/internal/checkpoint/checkpoint.go:188: | MergeInto | 88.9% |
+| github.com/cloudquery/plugin-sdk/v4/internal/checkpoint/checkpoint.go:203: | wait | 50.0% |
+| github.com/cloudquery/plugin-sdk/v4/internal/checkpoint/checkpoint.go:221: | Finish | 76.9% |
+| github.com/cloudquery/plugin-sdk/v4/internal/checkpoint/checkpoint.go:241: | Abort | 100.0% |
+| github.com/cloudquery/plugin-sdk/v4/internal/checkpoint/checkpoint.go:263: | Schedule | 82.4% |
+| github.com/cloudquery/plugin-sdk/v4/internal/checkpoint/checkpoint.go:324: | commonHolder | 42.9% |
+| github.com/cloudquery/plugin-sdk/v4/internal/checkpoint/checkpoint.go:337: | Collapse | 100.0% |
+| github.com/cloudquery/plugin-sdk/v4/internal/checkpoint/checkpoint.go:346: | Join | 100.0% |
+| github.com/cloudquery/plugin-sdk/v4/internal/checkpoint/checkpoint.go:373: | Checkpoint | 100.0% |
+| github.com/cloudquery/plugin-sdk/v4/internal/checkpoint/checkpoint.go:378: | flatten | 100.0% |
+| github.com/cloudquery/plugin-sdk/v4/internal/clients/state/v3/state.go:55: | WithCheckpoints | 0.0% |
+| github.com/cloudquery/plugin-sdk/v4/internal/clients/state/v3/state.go:66: | NewClient | 0.0% |
+| github.com/cloudquery/plugin-sdk/v4/internal/clients/state/v3/state.go:165: | SetKey | 0.0% |
+| github.com/cloudquery/plugin-sdk/v4/internal/clients/state/v3/state.go:203: | newScopeSet | 100.0% |
+| github.com/cloudquery/plugin-sdk/v4/internal/clients/state/v3/state.go:210: | add | 100.0% |
+| github.com/cloudquery/plugin-sdk/v4/internal/clients/state/v3/state.go:224: | Flush | 0.0% |
+| github.com/cloudquery/plugin-sdk/v4/internal/clients/state/v3/state.go:258: | flushCheckpoints | 0.0% |
+| github.com/cloudquery/plugin-sdk/v4/internal/clients/state/v3/state.go:303: | joinScopes | 0.0% |
+| github.com/cloudquery/plugin-sdk/v4/internal/clients/state/v3/state.go:321: | requeueAborted | 0.0% |
+| github.com/cloudquery/plugin-sdk/v4/internal/clients/state/v3/state.go:342: | unsent | 0.0% |
+| github.com/cloudquery/plugin-sdk/v4/internal/clients/state/v3/state.go:358: | record | 0.0% |
+| github.com/cloudquery/plugin-sdk/v4/internal/clients/state/v3/state.go:377: | GetKey | 0.0% |
+| github.com/cloudquery/plugin-sdk/v4/internal/clients/state/v3/state.go:383: | Close | 0.0% |
+| github.com/cloudquery/plugin-sdk/v4/internal/clients/state/v3/state.go:390: | Table | 0.0% |
 | github.com/cloudquery/plugin-sdk/v4/internal/deprecated/testing.go:10: | GenTestData | 0.0% |
 | github.com/cloudquery/plugin-sdk/v4/internal/memdb/memdb.go:31: | WithErrOnWrite | 100.0% |
 | github.com/cloudquery/plugin-sdk/v4/internal/memdb/memdb.go:37: | WithBlockingWrite | 0.0% |
@@ -105,13 +139,13 @@
 | github.com/cloudquery/plugin-sdk/v4/internal/memdb/memdb.go:170: | Sync | 0.0% |
 | github.com/cloudquery/plugin-sdk/v4/internal/memdb/memdb.go:187: | Tables | 100.0% |
 | github.com/cloudquery/plugin-sdk/v4/internal/memdb/memdb.go:195: | migrate | 100.0% |
-| github.com/cloudquery/plugin-sdk/v4/internal/memdb/memdb.go:213: | Write | 76.2% |
-| github.com/cloudquery/plugin-sdk/v4/internal/memdb/memdb.go:250: | Close | 0.0% |
-| github.com/cloudquery/plugin-sdk/v4/internal/memdb/memdb.go:255: | deleteStale | 88.9% |
-| github.com/cloudquery/plugin-sdk/v4/internal/memdb/memdb.go:282: | deleteRecord | 82.4% |
-| github.com/cloudquery/plugin-sdk/v4/internal/memdb/memdb.go:311: | Transform | 0.0% |
-| github.com/cloudquery/plugin-sdk/v4/internal/memdb/memdb.go:315: | TransformSchema | 0.0% |
-| github.com/cloudquery/plugin-sdk/v4/internal/memdb/memdb.go:319: | evaluatePredicate | 70.0% |
+| github.com/cloudquery/plugin-sdk/v4/internal/memdb/memdb.go:213: | Write | 77.3% |
+| github.com/cloudquery/plugin-sdk/v4/internal/memdb/memdb.go:252: | Close | 0.0% |
+| github.com/cloudquery/plugin-sdk/v4/internal/memdb/memdb.go:257: | deleteStale | 88.9% |
+| github.com/cloudquery/plugin-sdk/v4/internal/memdb/memdb.go:284: | deleteRecord | 82.4% |
+| github.com/cloudquery/plugin-sdk/v4/internal/memdb/memdb.go:313: | Transform | 0.0% |
+| github.com/cloudquery/plugin-sdk/v4/internal/memdb/memdb.go:317: | TransformSchema | 0.0% |
+| github.com/cloudquery/plugin-sdk/v4/internal/memdb/memdb.go:321: | evaluatePredicate | 70.0% |
 | github.com/cloudquery/plugin-sdk/v4/internal/pk/pk.go:10: | String | 0.0% |
 | github.com/cloudquery/plugin-sdk/v4/internal/random/random.go:16: | randSeq | 0.0% |
 | github.com/cloudquery/plugin-sdk/v4/internal/random/random.go:25: | GenerateRandomUnixSocketName | 0.0% |
@@ -159,23 +193,30 @@
 | github.com/cloudquery/plugin-sdk/v4/internal/servers/plugin/v3/assess.go:39: | tableFromBytes | 77.8% |
 | github.com/cloudquery/plugin-sdk/v4/internal/servers/plugin/v3/assess.go:54: | tableFindingToPB | 100.0% |
 | github.com/cloudquery/plugin-sdk/v4/internal/servers/plugin/v3/assess.go:78: | evidenceToPB | 100.0% |
-| github.com/cloudquery/plugin-sdk/v4/internal/servers/plugin/v3/plugin.go:36: | maxMsgSize | 100.0% |
-| github.com/cloudquery/plugin-sdk/v4/internal/servers/plugin/v3/plugin.go:43: | GetTables | 0.0% |
-| github.com/cloudquery/plugin-sdk/v4/internal/servers/plugin/v3/plugin.go:65: | GetName | 100.0% |
-| github.com/cloudquery/plugin-sdk/v4/internal/servers/plugin/v3/plugin.go:71: | GetVersion | 100.0% |
-| github.com/cloudquery/plugin-sdk/v4/internal/servers/plugin/v3/plugin.go:77: | GetSpecSchema | 0.0% |
-| github.com/cloudquery/plugin-sdk/v4/internal/servers/plugin/v3/plugin.go:86: | TestConnection | 0.0% |
-| github.com/cloudquery/plugin-sdk/v4/internal/servers/plugin/v3/plugin.go:119: | Init | 66.7% |
-| github.com/cloudquery/plugin-sdk/v4/internal/servers/plugin/v3/plugin.go:126: | Read | 0.0% |
-| github.com/cloudquery/plugin-sdk/v4/internal/servers/plugin/v3/plugin.go:163: | flushMetrics | 66.7% |
-| github.com/cloudquery/plugin-sdk/v4/internal/servers/plugin/v3/plugin.go:174: | Sync | 39.6% |
-| github.com/cloudquery/plugin-sdk/v4/internal/servers/plugin/v3/plugin.go:296: | sendInsert | 90.5% |
-| github.com/cloudquery/plugin-sdk/v4/internal/servers/plugin/v3/plugin.go:341: | maxRowsPerMessage | 75.0% |
-| github.com/cloudquery/plugin-sdk/v4/internal/servers/plugin/v3/plugin.go:349: | recordTableName | 100.0% |
-| github.com/cloudquery/plugin-sdk/v4/internal/servers/plugin/v3/plugin.go:354: | Write | 39.7% |
-| github.com/cloudquery/plugin-sdk/v4/internal/servers/plugin/v3/plugin.go:474: | Transform | 66.7% |
-| github.com/cloudquery/plugin-sdk/v4/internal/servers/plugin/v3/plugin.go:564: | TransformSchema | 70.0% |
-| github.com/cloudquery/plugin-sdk/v4/internal/servers/plugin/v3/plugin.go:580: | Close | 100.0% |
+| github.com/cloudquery/plugin-sdk/v4/internal/servers/plugin/v3/plugin.go:37: | maxMsgSize | 100.0% |
+| github.com/cloudquery/plugin-sdk/v4/internal/servers/plugin/v3/plugin.go:44: | GetTables | 0.0% |
+| github.com/cloudquery/plugin-sdk/v4/internal/servers/plugin/v3/plugin.go:66: | GetName | 100.0% |
+| github.com/cloudquery/plugin-sdk/v4/internal/servers/plugin/v3/plugin.go:72: | GetVersion | 100.0% |
+| github.com/cloudquery/plugin-sdk/v4/internal/servers/plugin/v3/plugin.go:78: | GetSpecSchema | 0.0% |
+| github.com/cloudquery/plugin-sdk/v4/internal/servers/plugin/v3/plugin.go:87: | TestConnection | 0.0% |
+| github.com/cloudquery/plugin-sdk/v4/internal/servers/plugin/v3/plugin.go:120: | Init | 66.7% |
+| github.com/cloudquery/plugin-sdk/v4/internal/servers/plugin/v3/plugin.go:128: | Read | 0.0% |
+| github.com/cloudquery/plugin-sdk/v4/internal/servers/plugin/v3/plugin.go:165: | flushMetrics | 66.7% |
+| github.com/cloudquery/plugin-sdk/v4/internal/servers/plugin/v3/plugin.go:176: | Sync | 43.1% |
+| github.com/cloudquery/plugin-sdk/v4/internal/servers/plugin/v3/plugin.go:308: | insertResponse | 100.0% |
+| github.com/cloudquery/plugin-sdk/v4/internal/servers/plugin/v3/plugin.go:318: | checkpointResponse | 100.0% |
+| github.com/cloudquery/plugin-sdk/v4/internal/servers/plugin/v3/plugin.go:328: | sendInsert | 100.0% |
+| github.com/cloudquery/plugin-sdk/v4/internal/servers/plugin/v3/plugin.go:333: | sendRecord | 90.5% |
+| github.com/cloudquery/plugin-sdk/v4/internal/servers/plugin/v3/plugin.go:372: | maxRowsPerMessage | 75.0% |
+| github.com/cloudquery/plugin-sdk/v4/internal/servers/plugin/v3/plugin.go:380: | recordTableName | 100.0% |
+| github.com/cloudquery/plugin-sdk/v4/internal/servers/plugin/v3/plugin.go:385: | Write | 43.2% |
+| github.com/cloudquery/plugin-sdk/v4/internal/servers/plugin/v3/plugin.go:446: | WriteStream | 0.0% |
+| github.com/cloudquery/plugin-sdk/v4/internal/servers/plugin/v3/plugin.go:521: | waitForFlush | 100.0% |
+| github.com/cloudquery/plugin-sdk/v4/internal/servers/plugin/v3/plugin.go:538: | flushResponse | 100.0% |
+| github.com/cloudquery/plugin-sdk/v4/internal/servers/plugin/v3/plugin.go:554: | writeRequestToMessage | 33.3% |
+| github.com/cloudquery/plugin-sdk/v4/internal/servers/plugin/v3/plugin.go:620: | Transform | 66.7% |
+| github.com/cloudquery/plugin-sdk/v4/internal/servers/plugin/v3/plugin.go:710: | TransformSchema | 70.0% |
+| github.com/cloudquery/plugin-sdk/v4/internal/servers/plugin/v3/plugin.go:726: | Close | 100.0% |
 | github.com/cloudquery/plugin-sdk/v4/internal/sha1/byteorder.go:3: | BEUint32 | 100.0% |
 | github.com/cloudquery/plugin-sdk/v4/internal/sha1/byteorder.go:8: | BEPutUint32 | 100.0% |
 | github.com/cloudquery/plugin-sdk/v4/internal/sha1/byteorder.go:16: | BEAppendUint32 | 100.0% |
@@ -210,19 +251,28 @@
 | github.com/cloudquery/plugin-sdk/v4/message/sync_message.go:102: | GetRecordsForTable | 0.0% |
 | github.com/cloudquery/plugin-sdk/v4/message/sync_message.go:121: | GetTable | 0.0% |
 | github.com/cloudquery/plugin-sdk/v4/message/sync_message.go:131: | GetTable | 0.0% |
-| github.com/cloudquery/plugin-sdk/v4/message/write_message.go:13: | IsWriteMessage | 0.0% |
-| github.com/cloudquery/plugin-sdk/v4/message/write_message.go:22: | InsertItems | 0.0% |
-| github.com/cloudquery/plugin-sdk/v4/message/write_message.go:32: | GetInserts | 0.0% |
-| github.com/cloudquery/plugin-sdk/v4/message/write_message.go:48: | GetTable | 0.0% |
-| github.com/cloudquery/plugin-sdk/v4/message/write_message.go:52: | Exists | 0.0% |
-| github.com/cloudquery/plugin-sdk/v4/message/write_message.go:58: | GetMessageByTable | 0.0% |
-| github.com/cloudquery/plugin-sdk/v4/message/write_message.go:72: | GetTable | 0.0% |
-| github.com/cloudquery/plugin-sdk/v4/message/write_message.go:82: | Exists | 0.0% |
-| github.com/cloudquery/plugin-sdk/v4/message/write_message.go:89: | GetRecords | 0.0% |
-| github.com/cloudquery/plugin-sdk/v4/message/write_message.go:97: | GetRecordsForTable | 0.0% |
-| github.com/cloudquery/plugin-sdk/v4/message/write_message.go:120: | GetTable | 0.0% |
-| github.com/cloudquery/plugin-sdk/v4/message/write_message.go:126: | Exists | 0.0% |
-| github.com/cloudquery/plugin-sdk/v4/message/write_message.go:167: | GetTable | 0.0% |
+| github.com/cloudquery/plugin-sdk/v4/message/sync_message.go:142: | GetTable | 0.0% |
+| github.com/cloudquery/plugin-sdk/v4/message/write_message.go:15: | IsWriteMessage | 0.0% |
+| github.com/cloudquery/plugin-sdk/v4/message/write_message.go:24: | InsertItems | 0.0% |
+| github.com/cloudquery/plugin-sdk/v4/message/write_message.go:34: | GetInserts | 0.0% |
+| github.com/cloudquery/plugin-sdk/v4/message/write_message.go:50: | GetTable | 0.0% |
+| github.com/cloudquery/plugin-sdk/v4/message/write_message.go:54: | Exists | 0.0% |
+| github.com/cloudquery/plugin-sdk/v4/message/write_message.go:60: | GetMessageByTable | 0.0% |
+| github.com/cloudquery/plugin-sdk/v4/message/write_message.go:74: | GetTable | 0.0% |
+| github.com/cloudquery/plugin-sdk/v4/message/write_message.go:84: | Exists | 0.0% |
+| github.com/cloudquery/plugin-sdk/v4/message/write_message.go:91: | GetRecords | 0.0% |
+| github.com/cloudquery/plugin-sdk/v4/message/write_message.go:99: | GetRecordsForTable | 0.0% |
+| github.com/cloudquery/plugin-sdk/v4/message/write_message.go:122: | GetTable | 0.0% |
+| github.com/cloudquery/plugin-sdk/v4/message/write_message.go:128: | Exists | 0.0% |
+| github.com/cloudquery/plugin-sdk/v4/message/write_message.go:169: | GetTable | 0.0% |
+| github.com/cloudquery/plugin-sdk/v4/message/write_message.go:185: | GetTable | 0.0% |
+| github.com/cloudquery/plugin-sdk/v4/message/write_message.go:190: | Done | 100.0% |
+| github.com/cloudquery/plugin-sdk/v4/message/write_message.go:195: | Result | 100.0% |
+| github.com/cloudquery/plugin-sdk/v4/message/write_message.go:199: | resultChan | 100.0% |
+| github.com/cloudquery/plugin-sdk/v4/message/write_message.go:210: | Error | 100.0% |
+| github.com/cloudquery/plugin-sdk/v4/message/write_message.go:217: | Unwrap | 100.0% |
+| github.com/cloudquery/plugin-sdk/v4/message/write_message.go:221: | FailedTables | 100.0% |
+| github.com/cloudquery/plugin-sdk/v4/message/write_message.go:230: | collectFailedTables | 100.0% |
 | github.com/cloudquery/plugin-sdk/v4/plugin/append_from_string.go:14: | appendFromString | 100.0% |
 | github.com/cloudquery/plugin-sdk/v4/plugin/diff.go:12: | RecordsDiff | 0.0% |
 | github.com/cloudquery/plugin-sdk/v4/plugin/diff.go:16: | TableDiff | 0.0% |
@@ -237,30 +287,32 @@
 | github.com/cloudquery/plugin-sdk/v4/plugin/options.go:32: | WithKind | 0.0% |
 | github.com/cloudquery/plugin-sdk/v4/plugin/options.go:43: | WithTeam | 0.0% |
 | github.com/cloudquery/plugin-sdk/v4/plugin/options.go:50: | WithConnectionTester | 0.0% |
+| github.com/cloudquery/plugin-sdk/v4/plugin/options.go:71: | WithFlushSupport | 0.0% |
 | github.com/cloudquery/plugin-sdk/v4/plugin/plugin.go:37: | Write | 0.0% |
 | github.com/cloudquery/plugin-sdk/v4/plugin/plugin.go:41: | Read | 0.0% |
 | github.com/cloudquery/plugin-sdk/v4/plugin/plugin.go:49: | Sync | 0.0% |
 | github.com/cloudquery/plugin-sdk/v4/plugin/plugin.go:53: | Tables | 0.0% |
 | github.com/cloudquery/plugin-sdk/v4/plugin/plugin.go:59: | Transform | 0.0% |
 | github.com/cloudquery/plugin-sdk/v4/plugin/plugin.go:62: | TransformSchema | 0.0% |
-| github.com/cloudquery/plugin-sdk/v4/plugin/plugin.go:108: | NewPlugin | 44.4% |
-| github.com/cloudquery/plugin-sdk/v4/plugin/plugin.go:132: | InvocationID | 0.0% |
-| github.com/cloudquery/plugin-sdk/v4/plugin/plugin.go:137: | Name | 0.0% |
-| github.com/cloudquery/plugin-sdk/v4/plugin/plugin.go:142: | Kind | 0.0% |
-| github.com/cloudquery/plugin-sdk/v4/plugin/plugin.go:147: | Team | 0.0% |
-| github.com/cloudquery/plugin-sdk/v4/plugin/plugin.go:152: | Version | 0.0% |
-| github.com/cloudquery/plugin-sdk/v4/plugin/plugin.go:156: | JSONSchema | 0.0% |
-| github.com/cloudquery/plugin-sdk/v4/plugin/plugin.go:160: | Meta | 100.0% |
-| github.com/cloudquery/plugin-sdk/v4/plugin/plugin.go:169: | PackageAndVersion | 0.0% |
-| github.com/cloudquery/plugin-sdk/v4/plugin/plugin.go:174: | SetSkipUsageClient | 0.0% |
-| github.com/cloudquery/plugin-sdk/v4/plugin/plugin.go:179: | SetSkipTableValidation | 0.0% |
-| github.com/cloudquery/plugin-sdk/v4/plugin/plugin.go:189: | OnBeforeSend | 0.0% |
-| github.com/cloudquery/plugin-sdk/v4/plugin/plugin.go:206: | OnSyncFinish | 0.0% |
-| github.com/cloudquery/plugin-sdk/v4/plugin/plugin.go:213: | Targets | 0.0% |
-| github.com/cloudquery/plugin-sdk/v4/plugin/plugin.go:217: | SetLogger | 0.0% |
-| github.com/cloudquery/plugin-sdk/v4/plugin/plugin.go:221: | Tables | 66.7% |
-| github.com/cloudquery/plugin-sdk/v4/plugin/plugin.go:233: | Init | 75.0% |
-| github.com/cloudquery/plugin-sdk/v4/plugin/plugin.go:263: | Close | 66.7% |
+| github.com/cloudquery/plugin-sdk/v4/plugin/plugin.go:110: | NewPlugin | 44.4% |
+| github.com/cloudquery/plugin-sdk/v4/plugin/plugin.go:134: | InvocationID | 0.0% |
+| github.com/cloudquery/plugin-sdk/v4/plugin/plugin.go:145: | SupportsFlush | 0.0% |
+| github.com/cloudquery/plugin-sdk/v4/plugin/plugin.go:156: | Name | 0.0% |
+| github.com/cloudquery/plugin-sdk/v4/plugin/plugin.go:161: | Kind | 0.0% |
+| github.com/cloudquery/plugin-sdk/v4/plugin/plugin.go:166: | Team | 0.0% |
+| github.com/cloudquery/plugin-sdk/v4/plugin/plugin.go:171: | Version | 0.0% |
+| github.com/cloudquery/plugin-sdk/v4/plugin/plugin.go:175: | JSONSchema | 0.0% |
+| github.com/cloudquery/plugin-sdk/v4/plugin/plugin.go:179: | Meta | 100.0% |
+| github.com/cloudquery/plugin-sdk/v4/plugin/plugin.go:188: | PackageAndVersion | 0.0% |
+| github.com/cloudquery/plugin-sdk/v4/plugin/plugin.go:193: | SetSkipUsageClient | 0.0% |
+| github.com/cloudquery/plugin-sdk/v4/plugin/plugin.go:198: | SetSkipTableValidation | 0.0% |
+| github.com/cloudquery/plugin-sdk/v4/plugin/plugin.go:208: | OnBeforeSend | 0.0% |
+| github.com/cloudquery/plugin-sdk/v4/plugin/plugin.go:225: | OnSyncFinish | 0.0% |
+| github.com/cloudquery/plugin-sdk/v4/plugin/plugin.go:232: | Targets | 0.0% |
+| github.com/cloudquery/plugin-sdk/v4/plugin/plugin.go:236: | SetLogger | 0.0% |
+| github.com/cloudquery/plugin-sdk/v4/plugin/plugin.go:240: | Tables | 66.7% |
+| github.com/cloudquery/plugin-sdk/v4/plugin/plugin.go:252: | Init | 75.0% |
+| github.com/cloudquery/plugin-sdk/v4/plugin/plugin.go:282: | Close | 66.7% |
 | github.com/cloudquery/plugin-sdk/v4/plugin/plugin_assess.go:29: | TableName | 80.0% |
 | github.com/cloudquery/plugin-sdk/v4/plugin/plugin_assess.go:76: | AssessTables | 87.5% |
 | github.com/cloudquery/plugin-sdk/v4/plugin/plugin_destination.go:20: | writeOne | 0.0% |
@@ -273,10 +325,10 @@
 | github.com/cloudquery/plugin-sdk/v4/plugin/plugin_package.go:62: | cgoEnvVariables | 0.0% |
 | github.com/cloudquery/plugin-sdk/v4/plugin/plugin_read.go:11: | readAll | 0.0% |
 | github.com/cloudquery/plugin-sdk/v4/plugin/plugin_read.go:27: | sliceToSingleRowRecord | 0.0% |
-| github.com/cloudquery/plugin-sdk/v4/plugin/plugin_source.go:39: | MatchesTable | 0.0% |
-| github.com/cloudquery/plugin-sdk/v4/plugin/plugin_source.go:57: | NewSourcePlugin | 0.0% |
-| github.com/cloudquery/plugin-sdk/v4/plugin/plugin_source.go:74: | SyncAll | 100.0% |
-| github.com/cloudquery/plugin-sdk/v4/plugin/plugin_source.go:90: | Sync | 62.5% |
+| github.com/cloudquery/plugin-sdk/v4/plugin/plugin_source.go:42: | MatchesTable | 0.0% |
+| github.com/cloudquery/plugin-sdk/v4/plugin/plugin_source.go:60: | NewSourcePlugin | 0.0% |
+| github.com/cloudquery/plugin-sdk/v4/plugin/plugin_source.go:77: | SyncAll | 100.0% |
+| github.com/cloudquery/plugin-sdk/v4/plugin/plugin_source.go:93: | Sync | 62.5% |
 | github.com/cloudquery/plugin-sdk/v4/plugin/plugin_testconn.go:14: | NewTestConnError | 0.0% |
 | github.com/cloudquery/plugin-sdk/v4/plugin/plugin_testconn.go:21: | Error | 0.0% |
 | github.com/cloudquery/plugin-sdk/v4/plugin/plugin_testconn.go:25: | Unwrap | 0.0% |
@@ -289,16 +341,17 @@
 | github.com/cloudquery/plugin-sdk/v4/plugin/testing.go:10: | tableNameForTest | 0.0% |
 | github.com/cloudquery/plugin-sdk/v4/plugin/testing_validation.go:10: | ValidateNoEmptyColumns | 0.0% |
 | github.com/cloudquery/plugin-sdk/v4/plugin/testing_validation.go:20: | ValidateSensitiveColumns | 0.0% |
-| github.com/cloudquery/plugin-sdk/v4/plugin/testing_write.go:90: | WithTestSourceAllowNull | 0.0% |
-| github.com/cloudquery/plugin-sdk/v4/plugin/testing_write.go:96: | WithTestIgnoreNullsInLists | 0.0% |
-| github.com/cloudquery/plugin-sdk/v4/plugin/testing_write.go:102: | WithTestDataOptions | 0.0% |
-| github.com/cloudquery/plugin-sdk/v4/plugin/testing_write.go:108: | WithRandomSeed | 0.0% |
-| github.com/cloudquery/plugin-sdk/v4/plugin/testing_write.go:114: | WithHomogeneousTypes | 0.0% |
-| github.com/cloudquery/plugin-sdk/v4/plugin/testing_write.go:120: | TestWriterSuiteRunner | 0.0% |
+| github.com/cloudquery/plugin-sdk/v4/plugin/testing_write.go:93: | WithTestSourceAllowNull | 0.0% |
+| github.com/cloudquery/plugin-sdk/v4/plugin/testing_write.go:99: | WithTestIgnoreNullsInLists | 0.0% |
+| github.com/cloudquery/plugin-sdk/v4/plugin/testing_write.go:105: | WithTestDataOptions | 0.0% |
+| github.com/cloudquery/plugin-sdk/v4/plugin/testing_write.go:111: | WithRandomSeed | 0.0% |
+| github.com/cloudquery/plugin-sdk/v4/plugin/testing_write.go:117: | WithHomogeneousTypes | 0.0% |
+| github.com/cloudquery/plugin-sdk/v4/plugin/testing_write.go:123: | TestWriterSuiteRunner | 0.0% |
 | github.com/cloudquery/plugin-sdk/v4/plugin/testing_write_delete.go:16: | testDeleteStaleBasic | 0.0% |
 | github.com/cloudquery/plugin-sdk/v4/plugin/testing_write_delete.go:83: | testDeleteStaleAll | 0.0% |
 | github.com/cloudquery/plugin-sdk/v4/plugin/testing_write_delete.go:153: | testDeleteRecordBasic | 0.0% |
 | github.com/cloudquery/plugin-sdk/v4/plugin/testing_write_delete.go:248: | testDeleteAllRecords | 0.0% |
+| github.com/cloudquery/plugin-sdk/v4/plugin/testing_write_flush.go:21: | testFlush | 0.0% |
 | github.com/cloudquery/plugin-sdk/v4/plugin/testing_write_insert.go:14: | TotalRows | 0.0% |
 | github.com/cloudquery/plugin-sdk/v4/plugin/testing_write_insert.go:22: | testInsertBasic | 0.0% |
 | github.com/cloudquery/plugin-sdk/v4/plugin/testing_write_insert.go:83: | testInsertAll | 0.0% |
@@ -537,17 +590,40 @@
 | github.com/cloudquery/plugin-sdk/v4/scheduler/batch.go:58: | WithBatchMaxSizeBytes | 0.0% |
 | github.com/cloudquery/plugin-sdk/v4/scheduler/batch.go:64: | WithBatchTimeout | 100.0% |
 | github.com/cloudquery/plugin-sdk/v4/scheduler/batch.go:70: | getBatcher | 100.0% |
-| github.com/cloudquery/plugin-sdk/v4/scheduler/batch.go:94: | process | 100.0% |
-| github.com/cloudquery/plugin-sdk/v4/scheduler/batch.go:98: | close | 0.0% |
-| github.com/cloudquery/plugin-sdk/v4/scheduler/batch.go:136: | send | 100.0% |
-| github.com/cloudquery/plugin-sdk/v4/scheduler/batch.go:164: | reachedSizeLimit | 100.0% |
-| github.com/cloudquery/plugin-sdk/v4/scheduler/batch.go:168: | work | 66.7% |
-| github.com/cloudquery/plugin-sdk/v4/scheduler/batch.go:211: | process | 87.5% |
-| github.com/cloudquery/plugin-sdk/v4/scheduler/batch.go:254: | close | 100.0% |
+| github.com/cloudquery/plugin-sdk/v4/scheduler/batch.go:97: | process | 100.0% |
+| github.com/cloudquery/plugin-sdk/v4/scheduler/batch.go:101: | flush | 100.0% |
+| github.com/cloudquery/plugin-sdk/v4/scheduler/batch.go:103: | close | 0.0% |
+| github.com/cloudquery/plugin-sdk/v4/scheduler/batch.go:141: | send | 100.0% |
+| github.com/cloudquery/plugin-sdk/v4/scheduler/batch.go:169: | reachedSizeLimit | 100.0% |
+| github.com/cloudquery/plugin-sdk/v4/scheduler/batch.go:174: | add | 100.0% |
+| github.com/cloudquery/plugin-sdk/v4/scheduler/batch.go:184: | work | 90.0% |
+| github.com/cloudquery/plugin-sdk/v4/scheduler/batch.go:226: | process | 87.0% |
+| github.com/cloudquery/plugin-sdk/v4/scheduler/batch.go:271: | flush | 63.6% |
+| github.com/cloudquery/plugin-sdk/v4/scheduler/batch.go:292: | close | 100.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/batchsender/batch_sender.go:79: | Flush | 100.0% |
+| github.com/cloudquery/plugin-sdk/v4/scheduler/batchsender/batch_sender.go:89: | Close | 100.0% |
+| github.com/cloudquery/plugin-sdk/v4/scheduler/checkpoint.go:64: | newSyncCheckpoints | 100.0% |
+| github.com/cloudquery/plugin-sdk/v4/scheduler/checkpoint.go:76: | send | 100.0% |
+| github.com/cloudquery/plugin-sdk/v4/scheduler/checkpoint.go:91: | sendAfterSync | 100.0% |
+| github.com/cloudquery/plugin-sdk/v4/scheduler/checkpoint.go:114: | returned | 100.0% |
+| github.com/cloudquery/plugin-sdk/v4/scheduler/checkpoint.go:128: | Checkpoint | 100.0% |
+| github.com/cloudquery/plugin-sdk/v4/scheduler/checkpoint.go:132: | Checkpoint | 100.0% |
+| github.com/cloudquery/plugin-sdk/v4/scheduler/checkpoint.go:147: | SendsAfter | 100.0% |
+| github.com/cloudquery/plugin-sdk/v4/scheduler/checkpoint.go:154: | complete | 84.2% |
+| github.com/cloudquery/plugin-sdk/v4/scheduler/checkpoint.go:181: | abort | 100.0% |
+| github.com/cloudquery/plugin-sdk/v4/scheduler/checkpoint.go:218: | newTableScope | 100.0% |
+| github.com/cloudquery/plugin-sdk/v4/scheduler/checkpoint.go:234: | Checkpoint | 100.0% |
+| github.com/cloudquery/plugin-sdk/v4/scheduler/checkpoint.go:250: | Collapsed | 100.0% |
+| github.com/cloudquery/plugin-sdk/v4/scheduler/checkpoint.go:260: | take | 100.0% |
+| github.com/cloudquery/plugin-sdk/v4/scheduler/checkpoint.go:269: | end | 100.0% |
+| github.com/cloudquery/plugin-sdk/v4/scheduler/checkpoint.go:282: | sendMessages | 100.0% |
+| github.com/cloudquery/plugin-sdk/v4/scheduler/checkpoint.go:292: | dropMessages | 100.0% |
+| github.com/cloudquery/plugin-sdk/v4/scheduler/checkpoint.go:310: | holdState | 93.8% |
+| github.com/cloudquery/plugin-sdk/v4/scheduler/checkpoint.go:356: | record | 90.9% |
+| github.com/cloudquery/plugin-sdk/v4/scheduler/checkpoint.go:377: | column | 83.3% |
 | 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% |
@@ -593,31 +669,34 @@
 | github.com/cloudquery/plugin-sdk/v4/scheduler/resolvers/resolvers.go:63: | ResolveResourcesChunkWithClassifier | 90.7% |
 | github.com/cloudquery/plugin-sdk/v4/scheduler/scheduler.go:57: | WithLogger | 100.0% |
 | github.com/cloudquery/plugin-sdk/v4/scheduler/scheduler.go:65: | WithErrorClassifier | 100.0% |
-| github.com/cloudquery/plugin-sdk/v4/scheduler/scheduler.go:71: | WithConcurrency | 0.0% |
+| github.com/cloudquery/plugin-sdk/v4/scheduler/scheduler.go:71: | WithConcurrency | 100.0% |
 | github.com/cloudquery/plugin-sdk/v4/scheduler/scheduler.go:77: | WithMaxDepth | 0.0% |
 | github.com/cloudquery/plugin-sdk/v4/scheduler/scheduler.go:83: | WithStrategy | 100.0% |
 | github.com/cloudquery/plugin-sdk/v4/scheduler/scheduler.go:89: | WithSingleNestedTableMaxConcurrency | 0.0% |
 | github.com/cloudquery/plugin-sdk/v4/scheduler/scheduler.go:95: | WithSingleResourceMaxConcurrency | 0.0% |
 | github.com/cloudquery/plugin-sdk/v4/scheduler/scheduler.go:103: | WithSyncDeterministicCQID | 100.0% |
 | github.com/cloudquery/plugin-sdk/v4/scheduler/scheduler.go:109: | WithInvocationID | 0.0% |
-| github.com/cloudquery/plugin-sdk/v4/scheduler/scheduler.go:115: | WithShard | 0.0% |
-| github.com/cloudquery/plugin-sdk/v4/scheduler/scheduler.go:172: | NewScheduler | 92.9% |
-| github.com/cloudquery/plugin-sdk/v4/scheduler/scheduler.go:211: | SyncAll | 0.0% |
-| github.com/cloudquery/plugin-sdk/v4/scheduler/scheduler.go:226: | Sync | 86.8% |
-| github.com/cloudquery/plugin-sdk/v4/scheduler/scheduler.go:304: | logTablesMetrics | 100.0% |
-| github.com/cloudquery/plugin-sdk/v4/scheduler/scheduler.go:313: | maxDepth | 100.0% |
-| github.com/cloudquery/plugin-sdk/v4/scheduler/scheduler.go:327: | shardTableClients | 100.0% |
+| github.com/cloudquery/plugin-sdk/v4/scheduler/scheduler.go:116: | withResClosedOnReturn | 100.0% |
+| github.com/cloudquery/plugin-sdk/v4/scheduler/scheduler.go:122: | WithShard | 0.0% |
+| github.com/cloudquery/plugin-sdk/v4/scheduler/scheduler.go:181: | NewScheduler | 100.0% |
+| github.com/cloudquery/plugin-sdk/v4/scheduler/scheduler.go:220: | SyncAll | 100.0% |
+| github.com/cloudquery/plugin-sdk/v4/scheduler/scheduler.go:235: | Sync | 87.5% |
+| github.com/cloudquery/plugin-sdk/v4/scheduler/scheduler.go:317: | processResources | 100.0% |
+| github.com/cloudquery/plugin-sdk/v4/scheduler/scheduler.go:350: | logTablesMetrics | 100.0% |
+| github.com/cloudquery/plugin-sdk/v4/scheduler/scheduler.go:359: | maxDepth | 100.0% |
+| github.com/cloudquery/plugin-sdk/v4/scheduler/scheduler.go:373: | 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:81: | resolveTableDfs | 100.0% |
-| github.com/cloudquery/plugin-sdk/v4/scheduler/scheduler_dfs.go:159: | resolveResourcesDfs | 69.6% |
+| github.com/cloudquery/plugin-sdk/v4/scheduler/scheduler_dfs.go:25: | syncDfs | 86.7% |
+| github.com/cloudquery/plugin-sdk/v4/scheduler/scheduler_dfs.go:82: | resolveTableDfs | 100.0% |
+| github.com/cloudquery/plugin-sdk/v4/scheduler/scheduler_dfs.go:174: | sendCheckpoints | 50.0% |
+| github.com/cloudquery/plugin-sdk/v4/scheduler/scheduler_dfs.go:180: | resolveResourcesDfs | 73.9% |
 | 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: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% |
-| github.com/cloudquery/plugin-sdk/v4/scheduler/scheduler_shuffle.go:81: | shuffle | 66.7% |
-| github.com/cloudquery/plugin-sdk/v4/scheduler/scheduler_shuffle_queue.go:10: | syncShuffleQueue | 94.4% |
+| github.com/cloudquery/plugin-sdk/v4/scheduler/scheduler_shuffle.go:81: | shuffle | 100.0% |
+| github.com/cloudquery/plugin-sdk/v4/scheduler/scheduler_shuffle_queue.go:12: | syncShuffleQueue | 94.4% |
 | github.com/cloudquery/plugin-sdk/v4/scheduler/strategy.go:14: | String | 66.7% |
 | github.com/cloudquery/plugin-sdk/v4/scheduler/strategy.go:22: | MarshalJSON | 0.0% |
 | github.com/cloudquery/plugin-sdk/v4/scheduler/strategy.go:35: | UnmarshalJSON | 0.0% |
@@ -776,14 +855,15 @@
 | github.com/cloudquery/plugin-sdk/v4/serve/plugin.go:98: | Serve | 77.8% |
 | github.com/cloudquery/plugin-sdk/v4/serve/plugin.go:114: | newCmdPluginServe | 70.1% |
 | github.com/cloudquery/plugin-sdk/v4/serve/plugin.go:286: | newCmdPluginRoot | 100.0% |
-| github.com/cloudquery/plugin-sdk/v4/state/client.go:30: | NewClient | 0.0% |
-| github.com/cloudquery/plugin-sdk/v4/state/client.go:34: | NewClientWithOptions | 0.0% |
-| github.com/cloudquery/plugin-sdk/v4/state/client.go:50: | NewConnectedClient | 0.0% |
-| github.com/cloudquery/plugin-sdk/v4/state/client.go:57: | NewConnectedClientWithOptions | 0.0% |
-| github.com/cloudquery/plugin-sdk/v4/state/client.go:90: | SetKey | 0.0% |
-| github.com/cloudquery/plugin-sdk/v4/state/client.go:94: | GetKey | 0.0% |
-| github.com/cloudquery/plugin-sdk/v4/state/client.go:98: | Flush | 0.0% |
-| github.com/cloudquery/plugin-sdk/v4/state/client.go:102: | Close | 0.0% |
+| github.com/cloudquery/plugin-sdk/v4/state/client.go:47: | NewClient | 0.0% |
+| github.com/cloudquery/plugin-sdk/v4/state/client.go:53: | NewClientWithOptions | 66.7% |
+| github.com/cloudquery/plugin-sdk/v4/state/client.go:61: | newStateClient | 0.0% |
+| github.com/cloudquery/plugin-sdk/v4/state/client.go:81: | NewConnectedClient | 0.0% |
+| github.com/cloudquery/plugin-sdk/v4/state/client.go:88: | NewConnectedClientWithOptions | 0.0% |
+| github.com/cloudquery/plugin-sdk/v4/state/client.go:129: | SetKey | 0.0% |
+| github.com/cloudquery/plugin-sdk/v4/state/client.go:133: | GetKey | 0.0% |
+| github.com/cloudquery/plugin-sdk/v4/state/client.go:137: | Flush | 0.0% |
+| github.com/cloudquery/plugin-sdk/v4/state/client.go:141: | Close | 0.0% |
 | github.com/cloudquery/plugin-sdk/v4/transformers/ignore_in_tests.go:7: | DefaultIgnoreInTestsTransformer | 100.0% |
 | github.com/cloudquery/plugin-sdk/v4/transformers/json_schema_fields.go:26: | jsonSchemaFields | 100.0% |
 | github.com/cloudquery/plugin-sdk/v4/transformers/json_schema_fields.go:39: | computeJSONSchemaFields | 100.0% |
@@ -921,60 +1001,68 @@
 | github.com/cloudquery/plugin-sdk/v4/types/uuid.go:220: | Deserialize | 0.0% |
 | github.com/cloudquery/plugin-sdk/v4/types/uuid.go:231: | ExtensionEquals | 100.0% |
 | github.com/cloudquery/plugin-sdk/v4/types/uuid.go:235: | NewBuilder | 100.0% |
-| github.com/cloudquery/plugin-sdk/v4/writers/batchwriter/batchwriter.go:47: | WithLogger | 0.0% |
-| github.com/cloudquery/plugin-sdk/v4/writers/batchwriter/batchwriter.go:53: | WithBatchTimeout | 100.0% |
-| github.com/cloudquery/plugin-sdk/v4/writers/batchwriter/batchwriter.go:59: | WithBatchSize | 100.0% |
-| github.com/cloudquery/plugin-sdk/v4/writers/batchwriter/batchwriter.go:65: | WithBatchSizeBytes | 100.0% |
-| github.com/cloudquery/plugin-sdk/v4/writers/batchwriter/batchwriter.go:82: | New | 100.0% |
-| github.com/cloudquery/plugin-sdk/v4/writers/batchwriter/batchwriter.go:99: | Flush | 81.8% |
-| github.com/cloudquery/plugin-sdk/v4/writers/batchwriter/batchwriter.go:116: | Close | 100.0% |
-| github.com/cloudquery/plugin-sdk/v4/writers/batchwriter/batchwriter.go:127: | worker | 87.8% |
-| github.com/cloudquery/plugin-sdk/v4/writers/batchwriter/batchwriter.go:199: | flushTable | 85.7% |
-| github.com/cloudquery/plugin-sdk/v4/writers/batchwriter/batchwriter.go:211: | flushMigrateTables | 87.5% |
-| github.com/cloudquery/plugin-sdk/v4/writers/batchwriter/batchwriter.go:224: | flushDeleteStaleTables | 50.0% |
-| github.com/cloudquery/plugin-sdk/v4/writers/batchwriter/batchwriter.go:237: | flushDeleteRecordTables | 50.0% |
-| github.com/cloudquery/plugin-sdk/v4/writers/batchwriter/batchwriter.go:250: | flushInsert | 100.0% |
-| github.com/cloudquery/plugin-sdk/v4/writers/batchwriter/batchwriter.go:264: | writeAll | 100.0% |
-| github.com/cloudquery/plugin-sdk/v4/writers/batchwriter/batchwriter.go:273: | Write | 31.8% |
-| github.com/cloudquery/plugin-sdk/v4/writers/batchwriter/batchwriter.go:342: | isLimitReached | 100.0% |
-| github.com/cloudquery/plugin-sdk/v4/writers/batchwriter/batchwriter.go:348: | startWorker | 91.3% |
+| github.com/cloudquery/plugin-sdk/v4/writers/batchwriter/batchwriter.go:59: | WithLogger | 0.0% |
+| github.com/cloudquery/plugin-sdk/v4/writers/batchwriter/batchwriter.go:65: | WithBatchTimeout | 100.0% |
+| github.com/cloudquery/plugin-sdk/v4/writers/batchwriter/batchwriter.go:71: | WithBatchSize | 100.0% |
+| github.com/cloudquery/plugin-sdk/v4/writers/batchwriter/batchwriter.go:77: | WithBatchSizeBytes | 100.0% |
+| github.com/cloudquery/plugin-sdk/v4/writers/batchwriter/batchwriter.go:94: | New | 100.0% |
+| github.com/cloudquery/plugin-sdk/v4/writers/batchwriter/batchwriter.go:112: | Flush | 100.0% |
+| github.com/cloudquery/plugin-sdk/v4/writers/batchwriter/batchwriter.go:133: | pendingDeleteStales | 80.0% |
+| github.com/cloudquery/plugin-sdk/v4/writers/batchwriter/batchwriter.go:143: | pendingDeleteRecords | 100.0% |
+| github.com/cloudquery/plugin-sdk/v4/writers/batchwriter/batchwriter.go:152: | Close | 100.0% |
+| github.com/cloudquery/plugin-sdk/v4/writers/batchwriter/batchwriter.go:163: | worker | 87.8% |
+| github.com/cloudquery/plugin-sdk/v4/writers/batchwriter/batchwriter.go:235: | flushTable | 100.0% |
+| github.com/cloudquery/plugin-sdk/v4/writers/batchwriter/batchwriter.go:250: | flushMigrateTables | 100.0% |
+| github.com/cloudquery/plugin-sdk/v4/writers/batchwriter/batchwriter.go:263: | flushDeleteStaleTables | 100.0% |
+| github.com/cloudquery/plugin-sdk/v4/writers/batchwriter/batchwriter.go:276: | flushDeleteRecordTables | 100.0% |
+| github.com/cloudquery/plugin-sdk/v4/writers/batchwriter/batchwriter.go:289: | flushInsert | 100.0% |
+| github.com/cloudquery/plugin-sdk/v4/writers/batchwriter/batchwriter.go:305: | trackFailures | 100.0% |
+| github.com/cloudquery/plugin-sdk/v4/writers/batchwriter/batchwriter.go:317: | newFailures | 100.0% |
+| github.com/cloudquery/plugin-sdk/v4/writers/batchwriter/batchwriter.go:335: | writeAll | 100.0% |
+| github.com/cloudquery/plugin-sdk/v4/writers/batchwriter/batchwriter.go:344: | Write | 68.1% |
+| github.com/cloudquery/plugin-sdk/v4/writers/batchwriter/batchwriter.go:420: | isLimitReached | 100.0% |
+| github.com/cloudquery/plugin-sdk/v4/writers/batchwriter/batchwriter.go:426: | startWorker | 91.3% |
 | github.com/cloudquery/plugin-sdk/v4/writers/batchwriter/unimplemented.go:13: | MigrateTables | 0.0% |
 | github.com/cloudquery/plugin-sdk/v4/writers/batchwriter/unimplemented.go:19: | DeleteStale | 0.0% |
 | github.com/cloudquery/plugin-sdk/v4/writers/batchwriter/unimplemented.go:25: | DeleteRecord | 0.0% |
 | github.com/cloudquery/plugin-sdk/v4/writers/mixedbatchwriter/mixedbatchwriter.go:35: | WithLogger | 0.0% |
 | github.com/cloudquery/plugin-sdk/v4/writers/mixedbatchwriter/mixedbatchwriter.go:41: | WithBatchSize | 100.0% |
 | github.com/cloudquery/plugin-sdk/v4/writers/mixedbatchwriter/mixedbatchwriter.go:47: | WithBatchSizeBytes | 100.0% |
-| github.com/cloudquery/plugin-sdk/v4/writers/mixedbatchwriter/mixedbatchwriter.go:53: | WithBatchTimeout | 0.0% |
+| github.com/cloudquery/plugin-sdk/v4/writers/mixedbatchwriter/mixedbatchwriter.go:53: | WithBatchTimeout | 100.0% |
 | github.com/cloudquery/plugin-sdk/v4/writers/mixedbatchwriter/mixedbatchwriter.go:59: | withTickerFn | 100.0% |
 | github.com/cloudquery/plugin-sdk/v4/writers/mixedbatchwriter/mixedbatchwriter.go:71: | New | 100.0% |
-| github.com/cloudquery/plugin-sdk/v4/writers/mixedbatchwriter/mixedbatchwriter.go:87: | Write | 82.1% |
-| github.com/cloudquery/plugin-sdk/v4/writers/mixedbatchwriter/mixedbatchwriter.go:175: | append | 60.0% |
-| github.com/cloudquery/plugin-sdk/v4/writers/mixedbatchwriter/mixedbatchwriter.go:185: | flush | 75.0% |
-| github.com/cloudquery/plugin-sdk/v4/writers/mixedbatchwriter/mixedbatchwriter.go:207: | append | 50.0% |
-| github.com/cloudquery/plugin-sdk/v4/writers/mixedbatchwriter/mixedbatchwriter.go:236: | flush | 78.6% |
+| github.com/cloudquery/plugin-sdk/v4/writers/mixedbatchwriter/mixedbatchwriter.go:87: | Write | 89.1% |
+| github.com/cloudquery/plugin-sdk/v4/writers/mixedbatchwriter/mixedbatchwriter.go:185: | append | 60.0% |
+| github.com/cloudquery/plugin-sdk/v4/writers/mixedbatchwriter/mixedbatchwriter.go:195: | flush | 75.0% |
+| github.com/cloudquery/plugin-sdk/v4/writers/mixedbatchwriter/mixedbatchwriter.go:217: | append | 50.0% |
+| github.com/cloudquery/plugin-sdk/v4/writers/mixedbatchwriter/mixedbatchwriter.go:246: | flush | 92.9% |
 | github.com/cloudquery/plugin-sdk/v4/writers/mixedbatchwriter/unimplemented.go:13: | MigrateTableBatch | 0.0% |
 | github.com/cloudquery/plugin-sdk/v4/writers/mixedbatchwriter/unimplemented.go:19: | DeleteStaleBatch | 0.0% |
 | github.com/cloudquery/plugin-sdk/v4/writers/mixedbatchwriter/unimplemented.go:25: | DeleteRecordsBatch | 0.0% |
 | github.com/cloudquery/plugin-sdk/v4/writers/msgtype.go:19: | MsgID | 0.0% |
-| github.com/cloudquery/plugin-sdk/v4/writers/streamingbatchwriter/streamingbatchwriter.go:79: | WithLogger | 0.0% |
-| github.com/cloudquery/plugin-sdk/v4/writers/streamingbatchwriter/streamingbatchwriter.go:85: | WithBatchTimeout | 100.0% |
-| github.com/cloudquery/plugin-sdk/v4/writers/streamingbatchwriter/streamingbatchwriter.go:91: | WithBatchSizeRows | 100.0% |
-| github.com/cloudquery/plugin-sdk/v4/writers/streamingbatchwriter/streamingbatchwriter.go:97: | WithBatchSizeBytes | 0.0% |
-| github.com/cloudquery/plugin-sdk/v4/writers/streamingbatchwriter/streamingbatchwriter.go:103: | withTickerFn | 100.0% |
-| github.com/cloudquery/plugin-sdk/v4/writers/streamingbatchwriter/streamingbatchwriter.go:115: | New | 100.0% |
-| github.com/cloudquery/plugin-sdk/v4/writers/streamingbatchwriter/streamingbatchwriter.go:131: | Flush | 68.4% |
-| github.com/cloudquery/plugin-sdk/v4/writers/streamingbatchwriter/streamingbatchwriter.go:157: | Close | 88.2% |
-| github.com/cloudquery/plugin-sdk/v4/writers/streamingbatchwriter/streamingbatchwriter.go:182: | Write | 94.7% |
-| github.com/cloudquery/plugin-sdk/v4/writers/streamingbatchwriter/streamingbatchwriter.go:215: | startWorker | 56.9% |
-| github.com/cloudquery/plugin-sdk/v4/writers/streamingbatchwriter/streamingbatchwriter.go:378: | closeFlush | 100.0% |
-| github.com/cloudquery/plugin-sdk/v4/writers/streamingbatchwriter/streamingbatchwriter.go:388: | send | 81.8% |
-| github.com/cloudquery/plugin-sdk/v4/writers/streamingbatchwriter/streamingbatchwriter.go:455: | run | 81.6% |
+| github.com/cloudquery/plugin-sdk/v4/writers/streamingbatchwriter/streamingbatchwriter.go:80: | WithLogger | 0.0% |
+| github.com/cloudquery/plugin-sdk/v4/writers/streamingbatchwriter/streamingbatchwriter.go:86: | WithBatchTimeout | 100.0% |
+| github.com/cloudquery/plugin-sdk/v4/writers/streamingbatchwriter/streamingbatchwriter.go:92: | WithBatchSizeRows | 100.0% |
+| github.com/cloudquery/plugin-sdk/v4/writers/streamingbatchwriter/streamingbatchwriter.go:98: | WithBatchSizeBytes | 0.0% |
+| github.com/cloudquery/plugin-sdk/v4/writers/streamingbatchwriter/streamingbatchwriter.go:104: | withTickerFn | 100.0% |
+| github.com/cloudquery/plugin-sdk/v4/writers/streamingbatchwriter/streamingbatchwriter.go:116: | New | 100.0% |
+| github.com/cloudquery/plugin-sdk/v4/writers/streamingbatchwriter/streamingbatchwriter.go:132: | Flush | 84.2% |
+| github.com/cloudquery/plugin-sdk/v4/writers/streamingbatchwriter/streamingbatchwriter.go:161: | commit | 100.0% |
+| github.com/cloudquery/plugin-sdk/v4/writers/streamingbatchwriter/streamingbatchwriter.go:178: | commitWorker | 87.5% |
+| github.com/cloudquery/plugin-sdk/v4/writers/streamingbatchwriter/streamingbatchwriter.go:197: | Close | 100.0% |
+| github.com/cloudquery/plugin-sdk/v4/writers/streamingbatchwriter/streamingbatchwriter.go:222: | Write | 100.0% |
+| github.com/cloudquery/plugin-sdk/v4/writers/streamingbatchwriter/streamingbatchwriter.go:264: | startWorker | 86.2% |
+| github.com/cloudquery/plugin-sdk/v4/writers/streamingbatchwriter/streamingbatchwriter.go:434: | closeFlush | 100.0% |
+| github.com/cloudquery/plugin-sdk/v4/writers/streamingbatchwriter/streamingbatchwriter.go:444: | send | 80.0% |
+| github.com/cloudquery/plugin-sdk/v4/writers/streamingbatchwriter/streamingbatchwriter.go:513: | run | 86.4% |
 | github.com/cloudquery/plugin-sdk/v4/writers/streamingbatchwriter/unimplemented.go:14: | MigrateTable | 0.0% |
 | github.com/cloudquery/plugin-sdk/v4/writers/streamingbatchwriter/unimplemented.go:24: | DeleteStale | 0.0% |
 | github.com/cloudquery/plugin-sdk/v4/writers/streamingbatchwriter/unimplemented.go:33: | DeleteRecords | 0.0% |
+| github.com/cloudquery/plugin-sdk/v4/writers/tables.go:10: | WithFailedTables | 100.0% |
+| github.com/cloudquery/plugin-sdk/v4/writers/tables.go:25: | tableName | 85.7% |
 | github.com/cloudquery/plugin-sdk/v4/writers/ticker.go:15: | NewTicker | 0.0% |
 | github.com/cloudquery/plugin-sdk/v4/writers/ticker.go:26: | Chan | 0.0% |
 | 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) | 57.8% |
+| total: | (statements) | 59.1% |