When running the distributed example, an exception is raised for all tasks run on nodes: Exception: Could not establish a connection to MongoDB.
Looking at cluster_scheduler.py, it gets the proper hostname but doesn't actually use it. I'm assuming then that the nodes try to use a db in their own localhost and can't find one.
When running the distributed example, an exception is raised for all tasks run on nodes:
Exception: Could not establish a connection to MongoDB.
Looking at cluster_scheduler.py, it gets the proper hostname but doesn't actually use it. I'm assuming then that the nodes try to use a db in their own localhost and can't find one.