Skip to content

Commit 737e8c5

Browse files
committed
chore: delete all non-config worker v1 code. (#13988)
1 parent ca7ff83 commit 737e8c5

File tree

89 files changed

+308
-6976
lines changed

Some content is hidden

Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.

89 files changed

+308
-6976
lines changed

airbyte-commons-worker/src/main/java/io/airbyte/workers/general/BufferedReplicationWorker.java

Lines changed: 5 additions & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -9,7 +9,6 @@
99
import datadog.trace.api.Trace;
1010
import io.airbyte.commons.concurrency.ClosableLinkedBlockingQueue;
1111
import io.airbyte.commons.concurrency.ClosableQueue;
12-
import io.airbyte.commons.envvar.EnvVar;
1312
import io.airbyte.commons.io.LineGobbler;
1413
import io.airbyte.commons.timer.Stopwatch;
1514
import io.airbyte.config.PerformanceMetrics;
@@ -156,11 +155,9 @@ public ReplicationOutput run(final ReplicationInput replicationInput, final Path
156155

157156
replicationWorkerHelper.markReplicationRunning();
158157

159-
if (replicationWorkerHelper.isWorkerV2TestEnabled()) {
160-
CompletableFuture.runAsync(
161-
replicationWorkerHelper.getWorkloadStatusHeartbeat(mdc),
162-
executors);
163-
}
158+
CompletableFuture.runAsync(
159+
replicationWorkerHelper.getWorkloadStatusHeartbeat(mdc),
160+
executors);
164161

165162
CompletableFuture.allOf(
166163
runAsyncWithHeartbeatCheck(this::readFromSource, mdc),
@@ -352,7 +349,7 @@ private void readFromSource() {
352349
}
353350
}
354351

355-
if (replicationWorkerHelper.isWorkerV2TestEnabled() && replicationWorkerHelper.getShouldAbort()) {
352+
if (replicationWorkerHelper.getShouldAbort()) {
356353
source.cancel();
357354
}
358355

@@ -547,8 +544,7 @@ private void recordErrorExitValue(final String connectionId, final String connec
547544
new MetricAttribute("connection_id", connectionId),
548545
new MetricAttribute("connector", connectorType),
549546
new MetricAttribute("image", connectorImage),
550-
new MetricAttribute("exit_value", exitValue),
551-
new MetricAttribute("execution_mode", Boolean.parseBoolean(EnvVar.MONO_POD.fetch(Boolean.FALSE.toString())) ? "mono-pod" : "triplet"));
547+
new MetricAttribute("exit_value", exitValue));
552548
}
553549

554550
}

airbyte-commons-worker/src/main/java/io/airbyte/workers/general/ReplicationWorkerFactory.java

Lines changed: 62 additions & 59 deletions
Large diffs are not rendered by default.

airbyte-commons-worker/src/main/java/io/airbyte/workers/internal/DefaultAirbyteDestination.java

Lines changed: 0 additions & 296 deletions
This file was deleted.

0 commit comments

Comments
 (0)