mirror of
https://github.com/google/nomulus.git
synced 2025-04-29 19:47:51 +02:00
parent
8d7088552f
commit
fea42831ae
3 changed files with 0 additions and 17 deletions
|
@ -1,5 +0,0 @@
|
||||||
<?xml version="1.0" encoding="UTF-8"?>
|
|
||||||
<!--TODO: ptkach - Remove this file after cloud scheduler is fully up and running -->
|
|
||||||
<cronentries>
|
|
||||||
|
|
||||||
</cronentries>
|
|
|
@ -75,9 +75,7 @@ public final class NordnUploadAction implements Runnable {
|
||||||
static final String PATH = "/_dr/task/nordnUpload";
|
static final String PATH = "/_dr/task/nordnUpload";
|
||||||
static final String LORDN_PHASE_PARAM = "lordnPhase";
|
static final String LORDN_PHASE_PARAM = "lordnPhase";
|
||||||
|
|
||||||
private static final int BATCH_SIZE = 1000;
|
|
||||||
private static final FluentLogger logger = FluentLogger.forEnclosingClass();
|
private static final FluentLogger logger = FluentLogger.forEnclosingClass();
|
||||||
private static final Duration LEASE_PERIOD = Duration.standardHours(1);
|
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* A unique (enough) id that is outputted in log lines to make it clear which log lines are
|
* A unique (enough) id that is outputted in log lines to make it clear which log lines are
|
||||||
|
|
|
@ -38,9 +38,6 @@ import static org.mockito.Mockito.verify;
|
||||||
import static org.mockito.Mockito.verifyNoInteractions;
|
import static org.mockito.Mockito.verifyNoInteractions;
|
||||||
import static org.mockito.Mockito.when;
|
import static org.mockito.Mockito.when;
|
||||||
|
|
||||||
import com.google.appengine.api.taskqueue.TaskHandle;
|
|
||||||
import com.google.appengine.api.taskqueue.TaskOptions;
|
|
||||||
import com.google.appengine.api.taskqueue.TaskOptions.Method;
|
|
||||||
import com.google.common.base.VerifyException;
|
import com.google.common.base.VerifyException;
|
||||||
import google.registry.batch.CloudTasksUtils;
|
import google.registry.batch.CloudTasksUtils;
|
||||||
import google.registry.model.domain.Domain;
|
import google.registry.model.domain.Domain;
|
||||||
|
@ -232,13 +229,6 @@ class NordnUploadActionTest {
|
||||||
.build());
|
.build());
|
||||||
}
|
}
|
||||||
|
|
||||||
private static TaskHandle makeTaskHandle(
|
|
||||||
String taskName, String tag, String payload, String queue) {
|
|
||||||
return new TaskHandle(
|
|
||||||
TaskOptions.Builder.withPayload(payload).method(Method.PULL).tag(tag).taskName(taskName),
|
|
||||||
queue);
|
|
||||||
}
|
|
||||||
|
|
||||||
private void verifyColumnCleared(String domainName) {
|
private void verifyColumnCleared(String domainName) {
|
||||||
VKey<Domain> domainKey = load(Domain.class, domainName, clock.nowUtc());
|
VKey<Domain> domainKey = load(Domain.class, domainName, clock.nowUtc());
|
||||||
Domain domain = loadByKey(domainKey);
|
Domain domain = loadByKey(domainKey);
|
||||||
|
|
Loading…
Add table
Reference in a new issue