![]() ![]() Launch_dir (str): directory where we want to write the blocks Njobs_block=500, sleep_time=None, reserve=False, strm_lvl='INFO', timeout=None, Look at the function definition and its docstring: def rapidfire(launchpad, fworker, qadapter, launch_dir='.', nlaunches=0, njobs_queue=0, Thanks for all the info, I have not tried it myself, but I think I know now what goes “wrong” (even if it actually is doing the correct thing.) Now that I have the source of the rapidfire line at the end of your script it is easier to answer. #You can also supply your own template by uncommenting and changing the following line: # You can override commands by uncommenting and changing the following lines: ![]() Host: mongodb+srv://dbUser: /test?retryWrites=true&w=majority Rapidfire(launchpad, FWorker(), CommonAdapter("SLURM", "fireworks_queue", rocket_launch="rlaunch singleshot"), reserve=False)įW_config.yaml LAUNCHPAD_LOC: '/shared/my_launchpad.yaml' Launchpad = LaunchPad(uri_mode=True, host=MONGO_HOST, logdir="/shared/testing/logs", strm_lvl="INFO", name="test", port=27017) MONGO_HOST="mongodb+srv://dbUser: /test?retryWrites=true&w=majority" Test.py from fireworks import Firework, Workflow, LaunchPad, ScriptTask, PyTaskįrom _launcher import rapidfireįrom er_objects.queue_mon_adapter import CommonAdapterįrom import FWorker When script is executed slurm starts to accept jobs but why more jobs than the 3 scripts that conform the workflow? In my case, Slurm accepts 20 jobs and I have no idea what they represent. The example runs as I copy here (I will remove this database after some time). I have created a test database only for this example in Mongo Atlas and it’s empty now (you can do lpad reset if you want). ![]()
0 Comments
Leave a Reply. |
AuthorWrite something about yourself. No need to be fancy, just an overview. ArchivesCategories |