in src/main/java/com/ericsson/gerrit/plugins/gcconductor/postgresqueue/DatabaseConstants.java [102:120]
static final String updateExecutor(
String executor, long queuedForLongerThan, Optional<String> queuedFrom) {
return format(
"UPDATE %s SET %s='%s' WHERE %s IN (SELECT %s FROM %s WHERE (%s is null OR %s='' OR %s='%s') AND age(localtimestamp, queued_at) > '%s' %s ORDER BY %s LIMIT 1 FOR UPDATE OF %s) RETURNING *",
REPOSITORIES_TABLE,
EXECUTOR,
executor,
REPOSITORY,
REPOSITORY,
REPOSITORIES_TABLE,
EXECUTOR,
EXECUTOR,
EXECUTOR,
executor,
queuedForLongerThan,
(queuedFrom.isPresent() ? " AND '" + queuedFrom.get() + "' LIKE hostname||'%'" : ""),
SEQUENCE,
REPOSITORIES_TABLE);
}