33from typing import Any , NamedTuple
44
55from common_library .json_serialization import json_dumps
6+ from common_library .serialization import model_dump_with_secrets
67from models_library .aiodocker_api import AioDockerServiceSpec
78from models_library .basic_types import BootModeEnum , PortInt
89from models_library .callbacks_mapping import CallbacksMapping
1920from servicelib .rabbitmq import RabbitMQRPCClient
2021from servicelib .rabbitmq .rpc_interfaces .efs_guardian import efs_manager
2122from servicelib .utils import unused_port
22- from settings_library .aws_s3_cli import AwsS3CliSettings
23- from settings_library .docker_registry import RegistrySettings
24- from settings_library .utils_encoders import create_json_encoder_wo_secrets
2523
2624from ....constants import DYNAMIC_SIDECAR_SCHEDULER_DATA_LABEL
2725from ....core .dynamic_services_settings .scheduler import (
@@ -101,8 +99,11 @@ def _get_environment_variables(
10199 app_settings .DYNAMIC_SERVICES .DYNAMIC_SIDECAR .DYNAMIC_SIDECAR_AWS_S3_CLI_SETTINGS
102100 and app_settings .DYNAMIC_SERVICES .DYNAMIC_SIDECAR .DYNAMIC_SIDECAR_AWS_S3_CLI_SETTINGS .AWS_S3_CLI_S3
103101 ):
104- dy_sidecar_aws_s3_cli_settings = app_settings .DYNAMIC_SERVICES .DYNAMIC_SIDECAR .DYNAMIC_SIDECAR_AWS_S3_CLI_SETTINGS .json (
105- encoder = create_json_encoder_wo_secrets (AwsS3CliSettings ),
102+ dy_sidecar_aws_s3_cli_settings = json_dumps (
103+ model_dump_with_secrets (
104+ app_settings .DYNAMIC_SERVICES .DYNAMIC_SIDECAR .DYNAMIC_SIDECAR_AWS_S3_CLI_SETTINGS ,
105+ show_secrets = True ,
106+ )
106107 )
107108
108109 state_exclude = set ()
@@ -133,7 +134,7 @@ def _get_environment_variables(
133134 "DY_SIDECAR_USER_SERVICES_HAVE_INTERNET_ACCESS" : f"{ allow_internet_access } " ,
134135 "DY_SIDECAR_SYSTEM_MONITOR_TELEMETRY_ENABLE" : f"{ telemetry_enabled } " ,
135136 "DY_SIDECAR_STATE_EXCLUDE" : json_dumps (f"{ x } " for x in state_exclude ),
136- "DY_SIDECAR_CALLBACKS_MAPPING" : callbacks_mapping .json (),
137+ "DY_SIDECAR_CALLBACKS_MAPPING" : callbacks_mapping .model_dump_json (),
137138 "DY_SIDECAR_STATE_PATHS" : json_dumps (
138139 f"{ x } " for x in scheduler_data .paths_mapping .state_paths
139140 ),
@@ -157,14 +158,22 @@ def _get_environment_variables(
157158 "RABBIT_PORT" : f"{ rabbit_settings .RABBIT_PORT } " ,
158159 "RABBIT_USER" : f"{ rabbit_settings .RABBIT_USER } " ,
159160 "RABBIT_SECURE" : f"{ rabbit_settings .RABBIT_SECURE } " ,
160- "DY_DEPLOYMENT_REGISTRY_SETTINGS" : app_settings .DIRECTOR_V2_DOCKER_REGISTRY .json (
161- encoder = create_json_encoder_wo_secrets (RegistrySettings ),
162- exclude = {"resolved_registry_url" , "api_url" },
161+ "DY_DEPLOYMENT_REGISTRY_SETTINGS" : (
162+ json_dumps (
163+ model_dump_with_secrets (
164+ app_settings .DIRECTOR_V2_DOCKER_REGISTRY ,
165+ show_secrets = True ,
166+ exclude = {"resolved_registry_url" , "api_url" },
167+ )
168+ )
163169 ),
164170 "DY_DOCKER_HUB_REGISTRY_SETTINGS" : (
165- app_settings .DIRECTOR_V2_DOCKER_HUB_REGISTRY .json (
166- encoder = create_json_encoder_wo_secrets (RegistrySettings ),
167- exclude = {"resolved_registry_url" , "api_url" },
171+ json_dumps (
172+ model_dump_with_secrets (
173+ app_settings .DIRECTOR_V2_DOCKER_HUB_REGISTRY ,
174+ show_secrets = True ,
175+ exclude = {"resolved_registry_url" , "api_url" },
176+ )
168177 )
169178 if app_settings .DIRECTOR_V2_DOCKER_HUB_REGISTRY
170179 else "null"
0 commit comments