[Bug]: returnvalue not JSON.stringified in python job

[klaemo]

Version

1.13.2

Platform

Python

What happened?

Writing a processor function that returns a plain string

async def process(job):
    return 'foo'

and listening to the queue events in JavaScript will throw an error when JavaScript tries to JSON.parse the return value:

SyntaxError: Unexpected token 'o', "foo" is not valid JSON
    at JSON.parse (<anonymous>)
    at QueueEvents.consumeEvents (/Users/clemens/Projects/bullmq-example/producer/node_modules/bullmq/dist/cjs/classes/queue-events.js:92:53)
    at process.processTicksAndRejections (node:internal/process/task_queues:95:5)
    at async QueueEvents.run (/Users/clemens/Projects/bullmq-example/producer/node_modules/bullmq/dist/cjs/classes/queue-events.js:60:17)

Similarily, returning an array will also fail

async def process(job):
    return ['foo']

Error processing job Invalid input of type: 'list'. Convert to a bytes, string, int or float first.

I think the python code should probably use json.dumps(result) here

bullmq/python/bullmq/worker.py

Line 167 in 3b67193

job.returnvalue = result

How to reproduce.

from bullmq import Worker

async def process(job):
    return 'foo'

async def main():
    # Feel free to remove the connection parameter, if your redis runs on localhost
    worker = Worker("myQueue", process, {"connection": "localhost"})

    # This while loop is just for the sake of this example
    # you won't need it in practice.
    while True: # Add some breaking conditions here
        await asyncio.sleep(1)

    # When no need to process more jobs we should close the worker
    await worker.close()

if __name__ == "__main__":
    asyncio.run(main())

const events = new QueueEvents("myQueue");

events.on("completed", (evt) => {
  console.log(evt);
});

Relevant log output

SyntaxError: Unexpected token 'o', "foo" is not valid JSON
    at JSON.parse (<anonymous>)
    at QueueEvents.consumeEvents (/Users/clemens/Projects/bullmq-example/producer/node_modules/bullmq/dist/cjs/classes/queue-events.js:92:53)
    at process.processTicksAndRejections (node:internal/process/task_queues:95:5)
    at async QueueEvents.run (/Users/clemens/Projects/bullmq-example/producer/node_modules/bullmq/dist/cjs/classes/queue-events.js:60:17)

Code of Conduct

• I agree to follow this project's Code of Conduct

[klaemo]

Wow, thank you so much for the quick fix! 🤩 Can confirm that it works as intended now.