ctx context.Context,
filter sqlplugin.ExecutionsFilter,
var executionVersion sqlplugin.ExecutionVersion
err := pdb.GetContext(ctx,
&executionVersion,
writeLockExecutionQuery,
filter.ShardID,
filter.NamespaceID,
filter.WorkflowID,
filter.RunID,
)
return executionVersion.DBRecordVersion, executionVersion.NextEventID, err
}
// InsertIntoCurrentExecutions inserts a single row into current_executions table