Skip to content

Commit 5d74505

Browse files
efs improvements
1 parent 1ee9895 commit 5d74505

File tree

1 file changed

+3
-7
lines changed

1 file changed

+3
-7
lines changed

services/director-v2/src/simcore_service_director_v2/modules/dynamic_sidecar/scheduler/_core/_event_create_sidecars.py

Lines changed: 3 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -181,7 +181,8 @@ async def action(cls, app: FastAPI, scheduler_data: SchedulerData) -> None:
181181
groups_extra_properties = get_repository(app, GroupsExtraPropertiesRepository)
182182

183183
assert scheduler_data.product_name is not None # nosec
184-
allow_internet_access: bool = await groups_extra_properties.has_internet_access(
184+
185+
user_extra_properties = await groups_extra_properties.get_user_extra_properties(
185186
user_id=scheduler_data.user_id, product_name=scheduler_data.product_name
186187
)
187188

@@ -194,7 +195,7 @@ async def action(cls, app: FastAPI, scheduler_data: SchedulerData) -> None:
194195
"uuid": f"{scheduler_data.node_uuid}", # needed for removal when project is closed
195196
},
196197
"Attachable": True,
197-
"Internal": not allow_internet_access,
198+
"Internal": not user_extra_properties.is_internet_enabled,
198199
}
199200
dynamic_sidecar_network_id = await create_network(network_config)
200201

@@ -217,11 +218,6 @@ async def action(cls, app: FastAPI, scheduler_data: SchedulerData) -> None:
217218
# generate a new `run_id` to avoid resource collisions
218219
scheduler_data.run_id = RunID.create()
219220

220-
# telemetry configuration
221-
user_extra_properties = await groups_extra_properties.get_user_extra_properties(
222-
user_id=scheduler_data.user_id, product_name=scheduler_data.product_name
223-
)
224-
225221
rpc_client: RabbitMQRPCClient = app.state.rabbitmq_rpc_client
226222

227223
# WARNING: do NOT log, this structure has secrets in the open

0 commit comments

Comments
 (0)