Skip to content

Commit 3e67514

Browse files
committed
chore: migrate airbyte-commons-temporal:main to kotlin (#16817)
1 parent 38034df commit 3e67514

35 files changed

+1220
-1288
lines changed

airbyte-commons-server/src/main/java/io/airbyte/commons/server/scheduler/DefaultSynchronousSchedulerClient.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -323,7 +323,7 @@ <T> SynchronousResponse<T> execute(final ConfigType configType,
323323
track(jobId, configType, connectorDefinitionId, workspaceId, actorId, actorType, JobState.STARTED, null);
324324
final TemporalResponse<ConnectorJobOutput> temporalResponse = executor.get();
325325
final Optional<ConnectorJobOutput> jobOutput = temporalResponse.getOutput();
326-
final JobState outputState = temporalResponse.getMetadata().isSucceeded() ? JobState.SUCCEEDED : JobState.FAILED;
326+
final JobState outputState = temporalResponse.metadata().succeeded() ? JobState.SUCCEEDED : JobState.FAILED;
327327

328328
track(jobId, configType, connectorDefinitionId, workspaceId, actorId, actorType, outputState, jobOutput.orElse(null));
329329

airbyte-commons-server/src/main/java/io/airbyte/commons/server/scheduler/SynchronousJobMetadata.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -60,9 +60,9 @@ public static SynchronousJobMetadata fromJobMetadata(final JobMetadata jobMetada
6060
configId,
6161
createdAt,
6262
endedAt,
63-
jobMetadata.isSucceeded(),
63+
jobMetadata.succeeded(),
6464
jobOutput != null ? jobOutput.getConnectorConfigurationUpdated() : false,
65-
jobMetadata.getLogPath(),
65+
jobMetadata.logPath(),
6666
jobOutput != null ? jobOutput.getFailureReason() : null);
6767
}
6868

airbyte-commons-server/src/main/java/io/airbyte/commons/server/scheduler/SynchronousResponse.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -58,10 +58,10 @@ public static <T> SynchronousResponse<T> fromTemporalResponse(final TemporalResp
5858
final Optional<ConnectorJobOutput> jobOutput = temporalResponse.getOutput();
5959
final T responseOutput = jobOutput.map(outputMapper).orElse(null);
6060

61-
final Path logPath = temporalResponse.getMetadata() == null ? null : temporalResponse.getMetadata().getLogPath();
61+
final Path logPath = temporalResponse.metadata() == null ? null : temporalResponse.metadata().logPath();
6262
final JobMetadata metadataResponse = responseOutput == null
6363
? new JobMetadata(false, logPath)
64-
: temporalResponse.getMetadata();
64+
: temporalResponse.metadata();
6565

6666
final SynchronousJobMetadata metadata = SynchronousJobMetadata.fromJobMetadata(
6767
metadataResponse,

airbyte-commons-temporal/src/main/java/io/airbyte/commons/temporal/ConnectionManagerUtils.java

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

airbyte-commons-temporal/src/main/java/io/airbyte/commons/temporal/JobMetadata.java

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

0 commit comments

Comments
 (0)