We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 64d20ea commit acd4e5dCopy full SHA for acd4e5d
airbyte-workers/src/main/kotlin/io/airbyte/workers/temporal/sync/SyncWorkflowV2Impl.kt
@@ -137,7 +137,7 @@ open class SyncWorkflowV2Impl : SyncWorkflowV2 {
137
): ConnectorJobOutput {
138
val workflowId = "replication_$jobId"
139
val taskQueue = getTaskQueue(TemporalJobType.SYNC)
140
- val childCheck =
+ val childReplicate =
141
Workflow.newChildWorkflowStub(
142
ConnectorCommandWorkflow::class.java,
143
ChildWorkflowOptions
@@ -148,7 +148,7 @@ open class SyncWorkflowV2Impl : SyncWorkflowV2 {
148
.build(),
149
)
150
151
- return childCheck.run(
+ return childReplicate.run(
152
ReplicationCommandApiInput(
153
ReplicationCommandApiInput.ReplicationApiInput(
154
connectionId = connectionId,
0 commit comments