Encapsulate job exceptions
Worker side:
File "/users/opid31/.conda/envs/ewoksworker/lib/python3.7/site-packages/ewokscore/task.py", line 55, in __init__
raise TaskInputError(f"Missing inputs for {type(self)}: {missing_required}")
ewokscore.task.TaskInputError: Missing inputs for <class 'ewoksxrpd.tasks.integrate.Integrate1D'>: {'energy', 'detector', 'geometry'}
Client side:
Traceback (most recent call last):
File "/users/blissadm/conda/miniconda/envs/bliss_dev/lib/python3.8/site-packages/kombu/serialization.py", line 39, in _reraise_errors
yield
File "/users/blissadm/conda/miniconda/envs/bliss_dev/lib/python3.8/site-packages/kombu/serialization.py", line 252, in loads
return decode(data)
File "/users/blissadm/conda/miniconda/envs/bliss_dev/lib/python3.8/site-packages/kombu/serialization.py", line 324, in unpickle
return pickle_loads(str_to_bytes(s))
File "/users/blissadm/conda/miniconda/envs/bliss_dev/lib/python3.8/site-packages/kombu/serialization.py", line 48, in pickle_loads
return load(BytesIO(s))
ModuleNotFoundError: No module named 'ewokscore'
During handling of the above exception, another exception occurred:
Traceback (most recent call last):
File "reprocess2.py", line 62, in <module>
submit(args=(workflow,), kwargs=kwargs).get()
File "/users/blissadm/conda/miniconda/envs/bliss_dev/lib/python3.8/site-packages/celery/result.py", line 224, in get
return self.backend.wait_for_pending(
File "/users/blissadm/conda/miniconda/envs/bliss_dev/lib/python3.8/site-packages/celery/backends/asynchronous.py", line 221, in wait_for_pending
for _ in self._wait_for_pending(result, **kwargs):
File "/users/blissadm/conda/miniconda/envs/bliss_dev/lib/python3.8/site-packages/celery/backends/asynchronous.py", line 287, in _wait_for_pending
for _ in self.drain_events_until(
File "/users/blissadm/conda/miniconda/envs/bliss_dev/lib/python3.8/site-packages/celery/backends/asynchronous.py", line 54, in drain_events_until
yield self.wait_for(p, wait, timeout=interval)
File "/users/blissadm/conda/miniconda/envs/bliss_dev/lib/python3.8/site-packages/celery/backends/asynchronous.py", line 63, in wait_for
wait(timeout=timeout)
File "/users/blissadm/conda/miniconda/envs/bliss_dev/lib/python3.8/site-packages/celery/backends/redis.py", line 155, in drain_events
self.on_state_change(self._decode_result(message['data']), message)
File "/users/blissadm/conda/miniconda/envs/bliss_dev/lib/python3.8/site-packages/celery/backends/base.py", line 430, in decode_result
return self.meta_from_decoded(self.decode(payload))
File "/users/blissadm/conda/miniconda/envs/bliss_dev/lib/python3.8/site-packages/celery/backends/base.py", line 436, in decode
return loads(payload,
File "/users/blissadm/conda/miniconda/envs/bliss_dev/lib/python3.8/site-packages/kombu/serialization.py", line 252, in loads
return decode(data)
File "/users/blissadm/conda/miniconda/envs/bliss_dev/lib/python3.8/contextlib.py", line 131, in __exit__
self.gen.throw(type, value, traceback)
File "/users/blissadm/conda/miniconda/envs/bliss_dev/lib/python3.8/site-packages/kombu/serialization.py", line 43, in _reraise_errors
reraise(wrapper, wrapper(exc), sys.exc_info()[2])
File "/users/blissadm/conda/miniconda/envs/bliss_dev/lib/python3.8/site-packages/kombu/exceptions.py", line 21, in reraise
raise value.with_traceback(tb)
File "/users/blissadm/conda/miniconda/envs/bliss_dev/lib/python3.8/site-packages/kombu/serialization.py", line 39, in _reraise_errors
yield
File "/users/blissadm/conda/miniconda/envs/bliss_dev/lib/python3.8/site-packages/kombu/serialization.py", line 252, in loads
return decode(data)
File "/users/blissadm/conda/miniconda/envs/bliss_dev/lib/python3.8/site-packages/kombu/serialization.py", line 324, in unpickle
return pickle_loads(str_to_bytes(s))
File "/users/blissadm/conda/miniconda/envs/bliss_dev/lib/python3.8/site-packages/kombu/serialization.py", line 48, in pickle_loads
return load(BytesIO(s))
kombu.exceptions.DecodeError: No module named 'ewokscore'