X-Git-Url: https://wannabe.guru.org/gitweb/?a=blobdiff_plain;f=remote_worker.py;h=42aeb854ce633b47e1f1be85b40bce8bf8d436f6;hb=559c60c169223c7c6833e9beedf978a8ffdd3926;hp=c04ac652449c5cb0e926ac35cc8fbaed7b05d7c4;hpb=b29be4f1750fd20bd2eada88e751dfae85817882;p=python_utils.git diff --git a/remote_worker.py b/remote_worker.py index c04ac65..42aeb85 100755 --- a/remote_worker.py +++ b/remote_worker.py @@ -51,9 +51,6 @@ cfg.add_argument( @background_thread def watch_for_cancel(terminate_event: threading.Event) -> None: - if platform.node() == 'VIDEO-COMPUTER': - logger.warning('Background thread not allowed on retarded computers, sorry.') - return logger.debug('Starting up background thread...') p = psutil.Process(os.getpid()) while True: @@ -83,6 +80,7 @@ def main() -> None: in_file = config.config['code_file'] out_file = config.config['result_file'] + stop_thread = None if config.config['watch_for_cancel']: (thread, stop_thread) = watch_for_cancel() @@ -130,8 +128,9 @@ def main() -> None: stop_thread.set() sys.exit(-1) - stop_thread.set() - thread.join() + if stop_thread is not None: + stop_thread.set() + thread.join() if __name__ == '__main__':