Method join

mongo_connector/connector.py:222–228

Joins thread, stops it from running

(self)

        return connector

    def join(self):
        """ Joins thread, stops it from running
        """
        self.can_run = False
        super(Connector, self).join()
        for dm in self.doc_managers:
            dm.stop()

    def write_oplog_progress(self):
        """ Writes oplog progress to file provided by user