Commit 0d0acc6d authored by Antoine Millet's avatar Antoine Millet
Browse files

Now create jobs directory if it doesn't exists

parent 25718769

cloudcontrol/node/host/__init__.py

+14 −0
Original line number Original line Diff line number Diff line
@@ -194,6 +194,20 @@ class Handler(BasePlugin): 
        self.commands = set()

        self.commands = set()





        #: jobs manager (different from MainLoop.jobs_manager)

        #: jobs manager (different from MainLoop.jobs_manager)

        try:

            os.makedirs(self.main.config.jobs_store_path, mode=0755)

        except OSError as e:

            if e.errno == 17:

                pass  # Ignore existing directory

            else:

                logger.critical('Cannot create jobs directory: %s', e)

                self.main.stop()

                raise

        except Exception as e:

            logger.critical('Cannot create jobs directory: %s', e)

            self.main.stop()

            raise



        try:

        try:

            self.jobs_manager = JobsManager(logger, NodeJobsManagerInterface(self),

            self.jobs_manager = JobsManager(logger, NodeJobsManagerInterface(self),

                                           JobsStore(self.main.config.jobs_store_path))

                                           JobsStore(self.main.config.jobs_store_path))