@jinuljt are the changes compatible with the MongoDB client version?
Also you can add a very simple test case, probably here:

• Settings
• Verify that source parameter is passed correctly to authenticate. You can probably find an example test case here.

What left to do to get this PR accepted? I've run into this issue at work and we've tested to confirm the fix here solves the issue.

It looks like the unit tests for this failed because they weren't updated to be compatible with the new format of the function call.

please add unittests

Is there any workaruond before this PR being merged? It has been 1 year ..

Unfortunately there are only two workaround options I can see until this is patched:

1. Monkey-patch the mongodb celery backend to update the function call
2. Store your data in the admin database used for authentication in mongodb.

Neither of these solutions is really ideal....

I opened a new PR to address this with the requested unittests here: #5527. The tests themselves pass but the current build is failing.

@duncaneddy Thanks for your reply!

I forked celery and created a release myself using your PR, then replaced celery with git+https://github.com/bwanglzu/celery@mongoauth#egg=celery in requirements.txt, through build not passing, it's working nicely for my celery project.

This is how I confg celery connection string:

from dotenv import load_dotenv, find_dotenv
load_dotenv(find_dotenv())

# MONGODB CONFIGURATIONS
base_url = None
if not os.environ.get('mongo.user') or not os.environ.get('mongo.password'):
    base_url = 'mongodb://' + os.environ.get('mongo.host') + ':' + os.environ.get('mongo.port')
else:
    base_url = "mongodb://" + os.environ.get('mongo.user') + ':' + os.environ.get('mongo.password') + '@' + \
        os.environ.get('mongo.host') + ':' + os.environ.get('mongo.port')
broker_url = base_url + '/' + os.environ.get('mongo.database') + '?authSource=' + os.environ.get('mongo.auth_source')
result_backend = base_url
mongodb_backend_settings = {
    'database': os.environ.get('mongo.database'),
    'taskmeta_collection': os.environ.get('mongo.collection'),
    'options': {'authSource': os.environ.get('mongo.auth_source')}
}

This PR has been superseded by #5527.
Thank you for your contribution. I'll make sure to mention you in the changelog.