64
dlqInternalErrors dynamicconfig.BoolPropertyFn,
65
dlqErrorPattern dynamicconfig.StringPropertyFn,
67
>
return &executableFactoryImpl{
68
>
executor: executor,
69
>
scheduler: scheduler,
70
>
rescheduler: rescheduler,
71
>
priorityAssigner: priorityAssigner,
72
>
timeSource: timeSource,
73
>
namespaceRegistry: namespaceRegistry,
74
>
clusterMetadata: clusterMetadata,
75
>
chasmRegistry: chasmRegistry,
76
>
taskTypeTagProvider: taskTypeTagProvider,
77
>
logger: logger,
78
>
metricsHandler: metricsHandler,
79
>
tracer: tracer,
80
>
dlqWriter: dlqWriter,
81
>
dlqEnabled: dlqEnabled,
82
>
attemptsBeforeSendingToDlq: attemptsBeforeSendingToDlq,
83
>
dlqInternalErrors: dlqInternalErrors,
84
>
dlqErrorPattern: dlqErrorPattern,
85
>
}
86
>
}
87
88
func (f *executableFactoryImpl) NewExecutable(task tasks.Task, readerID int64) Executable {