diff --git a/nomad/processing/base.py b/nomad/processing/base.py index 82d653916836e0638fab00a948f7f3a4b398ecdf..4d6a7bb4ab16a47405883c2800c521cdd35a4873 100644 --- a/nomad/processing/base.py +++ b/nomad/processing/base.py @@ -997,7 +997,11 @@ def process(is_blocking: bool = False, clear_queue_on_failure: bool = True, is_c kwargs['_meta_label'] = config.meta.label send_to_worker = self._sync_schedule_process(func_name, *args, **kwargs) if send_to_worker: - self._send_to_worker(func_name, *args, **kwargs) + try: + self._send_to_worker(func_name, *args, **kwargs) + except Exception as e: + self.fail(e) + raise setattr(wrapper, '__process_unwrapped', func) return wrapper diff --git a/requirements.txt b/requirements.txt index dcd43781a3bcf25580c425053ed0dd6d665be612..78b401bd8d550660df1e0b42a3b86e13f4fc134a 100644 --- a/requirements.txt +++ b/requirements.txt @@ -14,9 +14,9 @@ cachetools==4.2.4 docstring-parser==0.12 Pint==0.17 orjson==3.6.0 -click==7.1.2 +click==8.0.3 requests==2.27.1 -pytz==2021.1 +pytz==2021.3 aniso8601==7.0.0 ase==3.19.0 python-keycloak==0.26.1 @@ -54,7 +54,7 @@ optimade[mongo]==0.18.0 structlog==20.1.0 elasticsearch==7.17.1 msgpack==0.5.6 -celery[redis]==4.4.7 +celery[redis]==5.2.7 mongoengine==0.19.1 pymongo==3.12.1 Werkzeug==2.0.3 @@ -85,7 +85,7 @@ recommonmark==0.7.1 jinja2==3.0.3 rdflib==5.0.0 fastapi==0.65.3 -uvicorn[standard]==0.13.4 +uvicorn[standard]==0.18.3 python-multipart==0.0.5 jupyterhub==1.4.2 dockerspawner==12.1.0 @@ -109,6 +109,7 @@ pycodestyle==2.8.0 pytest==3.10.0 pytest-timeout==1.4.2 pytest-cov==2.7.1 +pytest-celery==0.0.0 rope==0.21.0 names==0.3.0 essential_generators==1.0