Skip to content

Commit 90c8da3

Browse files
committed
No-op.
PiperOrigin-RevId: 662331332
1 parent ffb176a commit 90c8da3

File tree

2 files changed

+10
-0
lines changed

2 files changed

+10
-0
lines changed

tfx/orchestration/experimental/core/env.py

Lines changed: 7 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -162,6 +162,10 @@ def get_status_code_from_exception(
162162
def maximum_active_task_schedulers(self) -> int:
163163
"""Returns the maximum number of active task schedulers."""
164164

165+
@abc.abstractmethod
166+
def get_pipeline_service_address(self) -> Optional[str]:
167+
"""Returns the pipeline service address."""
168+
165169

166170
class _DefaultEnv(Env):
167171
"""Default environment."""
@@ -251,6 +255,9 @@ def get_status_code_from_exception(
251255
def maximum_active_task_schedulers(self) -> int:
252256
return 1
253257

258+
def get_pipeline_service_address(self) -> Optional[str]:
259+
return None
260+
254261

255262
_ENV = _DefaultEnv()
256263

tfx/orchestration/experimental/core/env_test.py

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -103,6 +103,9 @@ def should_orchestrate(self, pipeline: pipeline_pb2.Pipeline) -> bool:
103103
def maximum_active_task_schedulers(self) -> int:
104104
raise NotImplementedError()
105105

106+
def get_pipeline_service_address(self) -> Optional[str]:
107+
raise NotImplementedError()
108+
106109

107110
class EnvTest(test_utils.TfxTest):
108111

0 commit comments

Comments
 (0)