diff --git a/setup.py b/setup.py new file mode 100644 index 0000000..9dbb74b --- /dev/null +++ b/setup.py @@ -0,0 +1,20 @@ +#!/usr/bin/python +# -*- coding: utf-8 -*- +# \file setup.py +# \brief TODO +# \author Florent Guiotte +# \version 0.1 +# \date 2 oct. 2018 +# +# TODO details + +from distutils.core import setup + +setup(name='minigrida', + version='1.11', + description='Simple and decentralized computing grid', + author='Florent Guiotte', + author_email='florent.guiotte@uhb.fr', + url='https://git.guiotte.fr/Florent/minigrida', + packages=['cvgenerators', 'descriptors', 'protocols'], + ) diff --git a/supervisor.py b/supervisor.py index 4b7c000..63cacb8 100644 --- a/supervisor.py +++ b/supervisor.py @@ -164,6 +164,9 @@ class ExpePath: def _get_complete_name(self): return self._get_hash_name() + '.yml' + def exists(self): + return self._actual.exists() + def stage(self, expe): log.info('Staging {}'.format(self._base_name)) self._check_hash(expe) @@ -219,7 +222,11 @@ def main(): watch_folder() continue try: - run(queue.pop()['expe_file']) + expe_file = queue.pop()['expe_file'] + while(not expe_file.exists() and queue): + expe_file = queue.pop()['expe_file'] + if expe_file.exists(): + run(expe_file) except TestError: log.warning('Test failed, error logged. Resuming') except Exception: