I'm currently running a Python script on my laptop which submits jobs to another computer's database (let's call it "Base") and I then connect to Base through ssh to execute "qlaunch -rh worker -ru michael rapidfire" in the command line (which will send the jobs to another computer called "worker"). I have Fireworks installed on all 3 computers and this works fine when my fireworks contain only built-in firetasks. However, when I include custom firetasks (in this case the RunQECalc task stored in run_qe_calc_task_v2.py) and try to run qlaunch I get the following error:
michael@Base:~/FireworkFiles/rocketruns$ qlaunch -rh worker -rc /home/michael/FireworkFiles/rocketruns/ -ru michael rapidfire --nlaunches 1
[worker] run: qlaunch rapidfire --nlaunches 1
[worker] out: 2016-07-07 09:56:59,786 INFO getting queue adapter
[worker] out: 2016-07-07 09:56:59,786 INFO Created new dir /home/michael/FireworkFiles/rocketruns/block_2016-07-07-15-56-59-786446
[worker] out: 2016-07-07 09:56:59,803 INFO The number of jobs currently in the queue is: 0
[worker] out: 2016-07-07 09:56:59,803 INFO 0 jobs in queue. Maximum allowed by user: 10
[worker] out: 2016-07-07 09:56:59,820 ERROR ----|vvv|----
[worker] out: 2016-07-07 09:56:59,820 ERROR Error with queue launcher rapid fire!
[worker] out: 2016-07-07 09:56:59,821 ERROR Traceback (most recent call last):
[worker] out: File "/usr/local/lib/python2.7/dist-packages/fireworks/queue/queue_launcher.py", line 192, in rapidfire
[worker] out: while jobs_in_queue < njobs_queue and launchpad.run_exists(fworker) \
[worker] out: File "/usr/local/lib/python2.7/dist-packages/fireworks/core/launchpad.py", line 511, in run_exists
[worker] out: return bool(self._get_a_fw_to_run(query=q, checkout=False))
[worker] out: File "/usr/local/lib/python2.7/dist-packages/fireworks/core/launchpad.py", line 663, in _get_a_fw_to_run
[worker] out: m_fw = self.get_fw_by_id(m_fw['fw_id'])
[worker] out: File "/usr/local/lib/python2.7/dist-packages/fireworks/core/launchpad.py", line 316, in get_fw_by_id
[worker] out: return Firework.from_dict(self.get_fw_dict_by_id(fw_id))
[worker] out: File "/usr/local/lib/python2.7/dist-packages/fireworks/utilities/fw_serializers.py", line 147, in _decorator
[worker] out: new_args[0] = {k: _recursive_load(v) for k, v in args[0].items()}
[worker] out: File "/usr/local/lib/python2.7/dist-packages/fireworks/utilities/fw_serializers.py", line 147, in <dictcomp>
[worker] out: new_args[0] = {k: _recursive_load(v) for k, v in args[0].items()}
[worker] out: File "/usr/local/lib/python2.7/dist-packages/fireworks/utilities/fw_serializers.py", line 108, in _recursive_load
[worker] out: return {k: _recursive_load(v) for k, v in obj.items()}
[worker] out: File "/usr/local/lib/python2.7/dist-packages/fireworks/utilities/fw_serializers.py", line 108, in <dictcomp>
[worker] out: return {k: _recursive_load(v) for k, v in obj.items()}
[worker] out: File "/usr/local/lib/python2.7/dist-packages/fireworks/utilities/fw_serializers.py", line 111, in _recursive_load
[worker] out: return [_recursive_load(v) for v in obj]
[worker] out: File "/usr/local/lib/python2.7/dist-packages/fireworks/utilities/fw_serializers.py", line 103, in _recursive_load
[worker] out: return load_object(obj)
[worker] out: File "/usr/local/lib/python2.7/dist-packages/fireworks/utilities/fw_serializers.py", line 306, in load_object
[worker] out: mod = __import__(modname, globals(), locals(), [classname], 0)
[worker] out: ImportError: No module named run_qe_calc_task_v2
[worker] out:
[worker] out: 2016-07-07 09:56:59,821 ERROR ----|^^^|----
[worker] out:
Disconnecting from worker... done.