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

FailStreamTask

class FailStreamTask(taskLauncher: DestinationTaskLauncher, exception: Exception, syncManager: SyncManager, stream: DestinationStream.Descriptor, shouldRunStreamLoaderClose: Boolean) : Task

Constructors

Link copied to clipboard
constructor(taskLauncher: DestinationTaskLauncher, exception: Exception, syncManager: SyncManager, stream: DestinationStream.Descriptor, shouldRunStreamLoaderClose: Boolean)

Properties

Link copied to clipboard
val log: KLogger
Link copied to clipboard

Functions

Link copied to clipboard
open suspend override fun execute()