+
+ it('Verify sendTaskFunctionOperationToWorker()', async () => {
+ const pool = new DynamicClusterPool(
+ Math.floor(numberOfWorkers / 2),
+ numberOfWorkers,
+ './tests/worker-files/cluster/testWorker.js'
+ )
+ const workerNodeKey = 0
+ await expect(
+ pool.sendTaskFunctionOperationToWorker(workerNodeKey, {
+ taskFunctionOperation: 'add',
+ taskFunctionName: 'empty',
+ taskFunction: (() => {}).toString()
+ })
+ ).resolves.toBe(true)
+ expect(
+ pool.workerNodes[workerNodeKey].info.taskFunctionNames
+ ).toStrictEqual([DEFAULT_TASK_NAME, 'test', 'empty'])
+ await pool.destroy()
+ })
+
+ it('Verify sendTaskFunctionOperationToWorkers()', async () => {
+ const pool = new DynamicClusterPool(
+ Math.floor(numberOfWorkers / 2),
+ numberOfWorkers,
+ './tests/worker-files/cluster/testWorker.js'
+ )
+ await waitPoolEvents(pool, PoolEvents.ready, 1)
+ await expect(
+ pool.sendTaskFunctionOperationToWorkers({
+ taskFunctionOperation: 'add',
+ taskFunctionName: 'empty',
+ taskFunction: (() => {}).toString()
+ })
+ ).resolves.toBe(true)
+ for (const workerNode of pool.workerNodes) {
+ expect(workerNode.info.taskFunctionNames).toStrictEqual([
+ DEFAULT_TASK_NAME,
+ 'test',
+ 'empty'
+ ])
+ }
+ await pool.destroy()
+ })