repository

type WorkflowConfigSnapshot struct {
	Id                           int                `sql:"id,pk"`
	WorkflowId                   int                `sql:"workflow_id,notnull"`
	WorkflowType                 types.WorkflowType `sql:"workflow_type,notnull"`
	PipelineId                   int                `sql:"pipeline_id,notnull"`
	WorkflowRequestJson          string             `sql:"workflow_request_json,notnull"`
	WorkflowRequestSchemaVersion string             `sql:"workflow_request_schema_version"`
	sql.AuditLog
	// contains filtered or unexported fields
}

type WorkflowConfigSnapshotRepository interface {
	SaveWithTx(tx *pg.Tx, snapshot *WorkflowConfigSnapshot) (*WorkflowConfigSnapshot, error)
	// New methods for retrigger functionality
	FindLatestFailedWorkflowSnapshot(workflowId int, workflowType types.WorkflowType) (*WorkflowConfigSnapshot, error)
	sql.TransactionWrapper
}

type WorkflowConfigSnapshotRepositoryImpl struct {
	*sql.TransactionUtilImpl
	// contains filtered or unexported fields
}