X-Git-Url: https://wannabe.guru.org/gitweb/?a=blobdiff_plain;f=src%2Fpyutils%2Fremote_worker.py;h=630d7e035fd414b166a1dda358ffd6aa430a70cd;hb=5bbcfd4dfccd411df0afd03f9790f67b4c852b9c;hp=cd6e4d6bdac48a47028ff26bbc1639a753276506;hpb=69566c003b4f1c3a4905f37d3735d7921502d14a;p=pyutils.git diff --git a/src/pyutils/remote_worker.py b/src/pyutils/remote_worker.py index cd6e4d6..630d7e0 100755 --- a/src/pyutils/remote_worker.py +++ b/src/pyutils/remote_worker.py @@ -4,6 +4,11 @@ """A simple utility to unpickle some code, run it, and pickle the results. Please don't unpickle (or run!) code you do not know. + +This script is used by code in parallelize, namely the +:class:`RemoteExecutor`, to schedule work on a remote machine. +The code in :file:`parallelize.py` uses a user-defined configuration +to schedule work this way. See that file for setup instructions. """ import logging @@ -92,7 +97,9 @@ def cleanup_and_exit( @bootstrap.initialize def main() -> None: in_file = config.config['code_file'] + assert in_file and type(in_file) == str out_file = config.config['result_file'] + assert out_file and type(out_file) == str thread = None stop_thread = None