Skip to content

Commit 7b9d296

Browse files
committed
switch between the 2 potential types
1 parent 8d4fd22 commit 7b9d296

File tree

3 files changed

+8
-5
lines changed

3 files changed

+8
-5
lines changed

tfx/orchestration/local/local_dag_runner.py

+4-1
Original file line numberDiff line numberDiff line change
@@ -50,7 +50,10 @@ def run_with_ir(self, pipeline: pipeline_pb2.Pipeline) -> None:
5050
})
5151

5252
deployment_config = runner_utils.extract_local_deployment_config(pipeline)
53-
connection_config = deployment_config.metadata_connection_config or deployment_config.mlmd_store_client_config
53+
if deployment_config.HasField('metadata_connection_config'):
54+
connection_config = deployment_config.metadata_connection_config
55+
else:
56+
connection_config = deployment_config.mlmd_store_client_config
5457

5558
logging.info('Using deployment config:\n %s', deployment_config)
5659
logging.info('Using connection config:\n %s', connection_config)

tfx/orchestration/local/runner_utils.py

+2-2
Original file line numberDiff line numberDiff line change
@@ -92,8 +92,8 @@ def _to_local_deployment(
9292
_build_local_platform_config(k, v))
9393

9494
if not input_config.metadata_connection_config.Unpack(
95-
result.metadata_connection_config) or not input_config.mlmd_store_client_config.Unpack(
96-
result.metadata_connection_config):
95+
result.metadata_connection_config) and not input_config.metadata_connection_config.Unpack(
96+
result.mlmd_store_client_config):
9797
raise ValueError('metadata_connection_config is expected to be in type '
9898
'ml_metadata.ConnectionConfig or ml_metadata.MetadataStoreClientConfig, but got type {}'.format(
9999
input_config.metadata_connection_config.type_url))

tfx/proto/orchestration/local_deployment_config.proto

+2-2
Original file line numberDiff line numberDiff line change
@@ -47,11 +47,11 @@ message LocalDeploymentConfig {
4747
// set custom driver logic.
4848
map<string, ExecutableSpec> custom_driver_specs = 2;
4949
// Connection config for ML-metadata.
50-
optional ml_metadata.ConnectionConfig metadata_connection_config = 3;
50+
ml_metadata.ConnectionConfig metadata_connection_config = 3;
5151
// A key from `node_id` to platform configs. Specifies platform settings to
5252
// pass to individual node operators.
5353
map<string, LocalPlatformConfig> node_level_platform_configs = 4;
5454
// Server Connection config
55-
optional ml_metadata.MetadataStoreClientConfig mlmd_store_client_config = 5;
55+
ml_metadata.MetadataStoreClientConfig mlmd_store_client_config = 5;
5656

5757
}

0 commit comments

Comments
 (0)