We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 18b3d87 commit 0003243Copy full SHA for 0003243
1 file changed
packages/pynumaflow/pynumaflow/shared/server.py
@@ -187,7 +187,9 @@ def start_multiproc_server(
187
188
if server_info is None:
189
server_info = ServerInfo.get_default_server_info()
190
- server_info.metadata = get_metadata_env(envs=METADATA_ENVS)
+ # Merge env metadata into existing metadata (preserving caller-set keys
191
+ # like MAP_MODE_KEY) rather than overwriting the entire dict.
192
+ server_info.metadata.update(get_metadata_env(envs=METADATA_ENVS))
193
# Add the MULTIPROC metadata using the number of servers to use
194
server_info.metadata[MULTIPROC_KEY] = str(process_count)
195
info_server_write(server_info=server_info, info_file=server_info_file)
0 commit comments