Skip to content

Commit ea8b11f

Browse files
committed
Also update lastModified for inserts
1 parent 4c606f2 commit ea8b11f

1 file changed

Lines changed: 1 addition & 0 deletions

File tree

flow/process_genericflow.go

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -445,6 +445,7 @@ func ProcessFlowStatesForInterval(tfContext FlowContext, tfmContext FlowMachineC
445445
rows, _ := tfmContext.CallDBQuery(tfContext, flowDefinitionContext.GetTableConfigurationById(tfContext.GetFlowHeader().SourceAlias, tfContext.GetFlowHeader().FlowName(), table[tableIndexKey].(string)), nil, false, "SELECT", nil, "")
446446
if len(rows) == 0 {
447447
tfmContext.CallDBQuery(tfContext, flowDefinitionContext.GetTableConfigurationInsert(table, tfContext.GetFlowHeader().SourceAlias, tfContext.GetFlowHeader().FlowName()), nil, true, "INSERT", []FlowNameType{tfContext.GetFlowHeader().FlowNameType()}, "") // if DNE -> insert
448+
updatedFlowTables = true
448449
} else {
449450
for _, value := range rows {
450451
// tableConfig is db, value is what's in vault...

0 commit comments

Comments
 (0)