TypeError: client.addJob is not a function about bullmq

[MichielvdVelde]

I'm getting the same error. I believe I have traced it to RedisConnection.waitUntilReady():

bullmq/src/classes/redis-connection.ts

Lines 41 to 50 in b96f5ba

	static async waitUntilReady(client: IORedis.Redis) {
	return new Promise(function(resolve, reject) {
	if (client.status === 'ready') {
	resolve();
	} else {
	async function handleReady() {
	client.removeListener('error', handleError);
	await load(client);
	resolve();
	}

I am providing the queue with a connected and ready connection. As such, the scripts are never loaded as handleReady() (and thus load) is never executed. I'm imagining what is required is some way of determining whether the scripts are loaded, and if not, load them before resolving the Promise.

The only two workarounds I have discovered so far are using a fresh Redis connection for every queue, or I will need to manually call load on the connection before passing it on. Not a major hassle, but possibly unexpected behavior nonetheless.

Edit: perhaps superfluously, a snippet of how I worked around this issue:

import IORedis from 'ioredis'
import { load, Queue } from 'bullmq'

const connection = new IORedis()

connection.once('ready', async () => {
  await load(connection)
  const queue = new Queue('name', { connection })
  // ...
})

Edit 2: Possibly related to #108 as well
Edit 3: I just noticed #59

[manast]

try with this change:

export async function addToQueue(queueName: string, data: any): void {
  await queues[queueName].waitUntilReady();
  return queues[queueName].add(queueName, data);
}

[manast]

I will leave this open because waitUntilReady should not be necessary, we overlooked it.

[mgan59]

I got jammed up by this issue, my implementation has a generator that fans out my tasks. Worked fine locally. But my deployment has a limit on redis-connections which blew up my worker. I figured I'd just share the redis connection which is when I started having error. The solution on issue #59 helped get me over the bump. Just an FYI to anyone else that lands here.

[manast]

🎉 This issue has been resolved in version 1.8.13 🎉

The release is available on:

• npm package (@latest dist-tag)
• GitHub release

Your semantic-release bot 📦🚀