+ /**
+ * Tasks queue back pressure size.
+ * This is the number of tasks that can be enqueued before the worker node has back pressure.
+ */
+ tasksQueueBackPressureSize: number
+ /**
+ * Callback invoked when worker node tasks queue is back pressured.
+ *
+ * @param workerId - The worker id.
+ */
+ onBackPressure?: (workerId: number) => void
+ /**
+ * Callback invoked when worker node tasks queue is empty.
+ *
+ * @param workerId - The worker id.
+ */
+ onEmptyQueue?: (workerId: number) => void