Fix YtStaticPart state

fix: add YtStaticPart state 2648fca1b7e856b7f946d7c79fe5620e59cd4604
doublecloud · Aug 29, 2024 · 4608658 · 4608658
1 parent 966d925
commit 4608658
Showing 1 changed file with 11 additions and 0 deletions.
diff --git a/transfer_manager/go/pkg/abstract/coordinator/transfer_state.go b/transfer_manager/go/pkg/abstract/coordinator/transfer_state.go
@@ -24,6 +24,16 @@ type MysqlBinlogPositionState struct {
 	Position int64
 }
 
+type YtStaticPartState struct {
+	SchemaName            string
+	TableName             string
+	PartID                string
+	RotatedShardedTableID string
+	YtTargetPath          string
+	YtShardTargetPath     string
+	YtShardTmpPath        string
+}
+
 // TransferStateData contain transfer state, shared across retries / restarts
 // can contain any generic information about transfer progress
 type TransferStateData struct {
@@ -36,6 +46,7 @@ type TransferStateData struct {
 	OraclePosition      *OraclePositionState
 	MysqlGtid           *MysqlGtidState
 	MysqlBinlogPosition *MysqlBinlogPositionState
+	YtStaticPart        *YtStaticPartState
 }
 
 func (s *TransferStateData) GetMysqlBinlogPosition() *MysqlBinlogPositionState {