We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent b434742 commit deed000Copy full SHA for deed000
services/sidecar/src/simcore_service_sidecar/executor.py
@@ -10,6 +10,7 @@
10
import attr
11
from celery.utils.log import get_task_logger
12
from packaging import version
13
+from tenacity import retry, stop_after_attempt
14
15
from servicelib.utils import fire_and_forget_task, logged_gather
16
from simcore_sdk import node_data, node_ports
@@ -156,6 +157,7 @@ async def _write_input_file(self, inputs: Dict) -> None:
156
157
file_name.write_text(json.dumps(inputs))
158
log.debug("Writing input file DONE")
159
160
+ @retry(reraise=True, stop=stop_after_attempt(3))
161
async def _pull_image(self):
162
docker_image = f"{config.DOCKER_REGISTRY}/{self.task.image['name']}:{self.task.image['tag']}"
163
log.debug(
0 commit comments