def _do_run(self):

        endpoint = self._endpoint(self.args)
        while True:
            # blocking call
            backup_msg = self.file_q.get()
            if backup_msg.file_ref:
                # a file was created or renamed, we have a stable ref
                with backup_msg.file_ref:
                    self._run_internal(endpoint, backup_msg.ks_manifest, 
                        backup_msg.component)
            else:
                # A file was deleted, no stable ref. 
                self._run_internal(endpoint, backup_msg.ks_manifest, 
                    backup_msg.component)
            self.file_q.task_done()
        return
Wait to get work from the :attr:`file_q`
dataset/ETHPy150Open amorton/cassback/cassback/subcommands/backup_subcommand.py/SnapWorkerThread._do_run