From fe41258117b00fc0bf9f5a5b1da802e68ce07a14 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Tha=C3=AFs=20de=20Boisfoss=C3=A9?= <4139100+Esadruhn@users.noreply.github.com> Date: Fri, 30 Sep 2022 13:09:22 +0200 Subject: [PATCH] Patch/0.38.1 (#298) --- substra/__version__.py | 2 +- substra/sdk/backends/remote/backend.py | 9 ++++++++- 2 files changed, 9 insertions(+), 2 deletions(-) diff --git a/substra/__version__.py b/substra/__version__.py index 978180b4..53b39ad3 100644 --- a/substra/__version__.py +++ b/substra/__version__.py @@ -1 +1 @@ -__version__ = "0.38.0" +__version__ = "0.38.1" diff --git a/substra/sdk/backends/remote/backend.py b/substra/sdk/backends/remote/backend.py index 578039d5..57fba465 100644 --- a/substra/sdk/backends/remote/backend.py +++ b/substra/sdk/backends/remote/backend.py @@ -206,7 +206,14 @@ def _add_tuples_from_computeplan(self, spec, spec_options, auto_batching, batch_ batches = [tuples] for batch in batches: - self._add_tuples(batch, spec_options) + try: + self._add_tuples(batch, spec_options) + except exceptions.AlreadyExists: + logger.warning( + "Skipping already submitted tasks, probably because of a timeout error. " + "Check that the compute plan has the right number of tasks once the submission is complete." + ) + continue def _add_tuples(self, batch, spec_options): batch_data = []