File tree 2 files changed +2
-8
lines changed
sidecar/src/simcore_service_sidecar
web/server/src/simcore_service_webserver
2 files changed +2
-8
lines changed Original file line number Diff line number Diff line change @@ -117,9 +117,7 @@ async def preprocess(self):
117
117
self .shared_folders .create ()
118
118
host_name = config .SIDECAR_HOST_HOSTNAME_PATH .read_text ()
119
119
await self ._post_messages (LogType .LOG , f"[sidecar]Running on { host_name } " )
120
- results = await logged_gather (
121
- self ._process_task_inputs (), self ._pull_image (), reraise = True
122
- )
120
+ results = await logged_gather (self ._process_task_inputs (), self ._pull_image ())
123
121
await self ._write_input_file (results [0 ])
124
122
log .debug ("Pre-Processing Pipeline DONE" )
125
123
@@ -241,13 +239,10 @@ async def _pull_image(self):
241
239
if "io.simcore.integration-version" in image_cfg ["Config" ]["Labels" ]:
242
240
self .integration_version = version .parse (
243
241
json .loads (
244
- image_cfg ["Config" ]["Labels" ][
245
- "io.simcore.integration-version"
246
- ]
242
+ image_cfg ["Config" ]["Labels" ]["io.simcore.integration-version" ]
247
243
)["integration-version" ]
248
244
)
249
245
250
-
251
246
async def _create_container_config (self , docker_image : str ) -> Dict :
252
247
# NOTE: Env/Binds for log folder is only necessary for integraion "0"
253
248
env_vars = [
Original file line number Diff line number Diff line change @@ -448,4 +448,3 @@ async def get_task_output(
448
448
comp_task = await result .fetchone ()
449
449
if comp_task :
450
450
return comp_task .outputs
451
- return None
You can’t perform that action at this time.
0 commit comments