86
}
87
88
>
func (f *executableFactoryImpl) NewExecutable(task tasks.Task, readerID int64) Executable {
executable_factory.go
89
>
return NewExecutable(
90
>
readerID,
91
>
task,
92
>
f.executor,
93
>
f.scheduler,
94
>
f.rescheduler,
95
>
f.priorityAssigner,
96
>
f.timeSource,
97
>
f.namespaceRegistry,
98
>
f.clusterMetadata,
99
>
f.chasmRegistry,
100
>
f.taskTypeTagProvider,
101
>
f.logger,
102
>
f.metricsHandler,
103
>
f.tracer,
104
>
func(params *ExecutableParams) {
105
>
params.DLQEnabled = f.dlqEnabled
106
>
params.DLQWriter = f.dlqWriter
107
>
params.MaxUnexpectedErrorAttempts = f.attemptsBeforeSendingToDlq
108
>
params.DLQInternalErrors = f.dlqInternalErrors
109
>
params.DLQErrorPattern = f.dlqErrorPattern
110
>
},
111
)
112
}