fireworks.core.firework import FWAction, FireTaskBasefrom fireworks import Firework, FWorker, LaunchPadfrom fireworks.core.rocket_launcher import launch_rocket
class getInput(FireTaskBase): _fw_name = "Addition Task" def run_task(self, fw_spec): input_array = fw_spec['input_array'] m_sum = sum(input_array) print("The sum of {} is: {}".format(input_array, m_sum)) return FWAction(stored_data={'sum': m_sum}, mod_spec=[{'_push': {'input_array': m_sum}}])
# set up the LaunchPad and reset itlaunchpad = LaunchPad()launchpad.reset('', require_password=False)
# create the Firework consisting of a custom "Addition" taskfirework = Firework(getInput(), spec={"input_array": [1, 2]})
# store workflow and launch it locallylaunchpad.add_wf(firework)launch_rocket(launchpad, FWorker())
_fw_name = "Addition Task2"
To view this discussion on the web visit https://groups.google.com/d/msgid/fireworkflows/4df8b3a6-a071-4004-b34e-23ce3433656f%40googlegroups.com.--
You received this message because you are subscribed to the Google Groups "fireworkflows" group.
To unsubscribe from this group and stop receiving emails from it, send an email to fireworkflow...@googlegroups.com.
from fireworks.core.firework import FWAction, FireTaskBase
from fireworks import Firework, FWorker, LaunchPadfrom fireworks.core.rocket_launcher import launch_rocket
from fireworks.utilities.fw_utilities import explicit_serialize
@explicit_serializeclass getInput(FireTaskBase): _fw_name = "Addition Task 2"
def run_task(self, fw_spec): input_array = fw_spec['input_array'] m_sum = sum(input_array) print("The sum of {} is: {}".format(input_array, m_sum)) return FWAction(stored_data={'sum': m_sum}, mod_spec=[{'_push': {'input_array': m_sum}}])
# set up the LaunchPad and reset it
launchpad = LaunchPad()launchpad.reset('', require_password=False)
# create the Firework consisting of a custom "Addition" taskfirework = Firework(getInput(), spec={"input_array": [1, 2]})
# store workflow and launch it locallylaunchpad.add_wf(firework)launch_rocket(launchpad, FWorker())
> lpad get_fws
Traceback (most recent call last): File "/usr/common/usg/python/fireworks/1.07-2.7.9/bin/lpad", line 6, in <module> lpad() File "/usr/common/usg/python/fireworks/1.07-2.7.9/lib/python2.7/site-packages/fireworks/scripts/lpad_run.py", line 877, in lpad args.func(args) File "/usr/common/usg/python/fireworks/1.07-2.7.9/lib/python2.7/site-packages/fireworks/scripts/lpad_run.py", line 194, in get_fws fw = lp.get_fw_by_id(id) File "/usr/common/usg/python/fireworks/1.07-2.7.9/lib/python2.7/site-packages/fireworks/core/launchpad.py", line 289, in get_fw_by_id return Firework.from_dict(fw_dict) File "/usr/common/usg/python/fireworks/1.07-2.7.9/lib/python2.7/site-packages/fireworks/utilities/fw_serializers.py", line 144, in _decorator new_args[0] = {k: _recursive_load(v) for k, v in args[0].items()} File "/usr/common/usg/python/fireworks/1.07-2.7.9/lib/python2.7/site-packages/fireworks/utilities/fw_serializers.py", line 144, in <dictcomp> new_args[0] = {k: _recursive_load(v) for k, v in args[0].items()} File "/usr/common/usg/python/fireworks/1.07-2.7.9/lib/python2.7/site-packages/fireworks/utilities/fw_serializers.py", line 105, in _recursive_load return {k: _recursive_load(v) for k, v in obj.items()} File "/usr/common/usg/python/fireworks/1.07-2.7.9/lib/python2.7/site-packages/fireworks/utilities/fw_serializers.py", line 105, in <dictcomp> return {k: _recursive_load(v) for k, v in obj.items()} File "/usr/common/usg/python/fireworks/1.07-2.7.9/lib/python2.7/site-packages/fireworks/utilities/fw_serializers.py", line 108, in _recursive_load return [_recursive_load(v) for v in obj] File "/usr/common/usg/python/fireworks/1.07-2.7.9/lib/python2.7/site-packages/fireworks/utilities/fw_serializers.py", line 104, in _recursive_load return load_object(obj) File "/usr/common/usg/python/fireworks/1.07-2.7.9/lib/python2.7/site-packages/fireworks/utilities/fw_serializers.py", line 295, in load_object mod = __import__(modname, globals(), locals(), [classname], 0)ImportError: No module named temp
from fireworks.utilities.fw_utilities import explicit_serialize
To view this discussion on the web visit https://groups.google.com/d/msgid/fireworkflows/a285f16e-9643-4a5d-b393-d0fb34ba0b0e%40googlegroups.com.