bulk-cdk-core-load/io.airbyte.cdk.load.task.implementor/FailStreamTaskFactory

FailStreamTaskFactory

@Singleton
class FailStreamTaskFactory(syncManager: SyncManager)

Constructors

Link copied to clipboard
constructor(syncManager: SyncManager)

Functions

Link copied to clipboard
fun make(taskLauncher: DestinationTaskLauncher, exception: Exception, stream: DestinationStream.Descriptor, shouldRunStreamLoaderClose: Boolean): FailStreamTask