bulk-cdk-toolkit-load-object-storage/io.airbyte.cdk.load.factory.object_storage/ObjectLoaderQueueBeanFactory/completedUploadQueue

completedUploadQueue

@Singleton
@Named(value = "fileCompletedQueue")
@Requires(condition = IsFileTransferCondition::class)
fun <T> completedUploadQueue(): StrictPartitionedQueue<PipelineEvent<StreamKey, ObjectLoaderUploadCompleter.UploadResult<T>>>

Completed file uploads.