ctx context.Context,
filter sqlplugin.ExecutionsFilter,
var executionVersion sqlplugin.ExecutionVersion
err := mdb.conn.GetContext(ctx,
&executionVersion,
readLockExecutionQuery,
filter.ShardID,
filter.NamespaceID,
filter.WorkflowID,
filter.RunID,
)
return executionVersion.DBRecordVersion, executionVersion.NextEventID, err
}
// WriteLockExecutions acquires a write lock on a single row in executions table