DestinationTaskLauncher
constructor(taskScopeProvider: TaskScopeProvider, catalog: DestinationCatalog, config: DestinationConfiguration, syncManager: SyncManager, inputConsumerTask: InputConsumerTask? = null, heartbeatTask: HeartbeatTask? = null, updateBatchTask: UpdateBatchStateTaskFactory, statsEmitter: StatsEmitter? = null, setupTaskFactory: SetupTaskFactory, openStreamTask: OpenStreamTask, closeStreamTaskFactory: CloseStreamTaskFactory, teardownTaskFactory: TeardownTaskFactory, loadPipeline: LoadPipeline?, updateCheckpointsTask: UpdateCheckpointsTask, failStreamTaskFactory: FailStreamTaskFactory, failSyncTaskFactory: FailSyncTaskFactory, @Named(value = "openStreamQueue") openStreamQueue: MessageQueue<DestinationStream>, @Named(value = "defaultDestinationTaskLauncherHasThrown") hasThrown: AtomicBoolean)