def METHOD_NAME(self):
    os.environ[
        "TF_CONFIG"
    ] = '{"cluster": { \
        "ps": ["web04-pod2.default.svc:5002"],\
        "chief":["p1.default.svc:5001"],\
        "worker": ["web04-pod1.default.svc:5000"]},\
        "task": {"type": "worker", "index": 0}}'
    base_executor = BaseExecutor()
    base_executor.get_cluster_info_by_tf_config()
    cluster_spec = {
        "ps": ["web04-pod2.default.svc:5002"],
        "chief": ["p1.default.svc:5001"],
        "worker": ["web04-pod1.default.svc:5000"],
    }
    estimator_run_config = base_executor.get_config(cluster_spec)
    sess_config = estimator_run_config._session_config
    self.assertEqual(
        estimator_run_config._master, "grpc://web04-pod1.default.svc:5000"
    )
    self.assertEqual(
        sess_config.experimental.share_session_state_in_clusterspec_propagation,  # noqa: E501
        True,
    )
    self.assertEqual(estimator_run_config._task_type, "worker")
    self.assertEqual(estimator_run_config._task_id, 1)