Skip to content

Commit 377fce1

Browse files
committed
fix: java to proto failing
- changed java_outer_classname for Permission.proto and Policy.proto - removed experimental optional from permission proto Signed-off-by: Theodor Mihalache <[email protected]>
1 parent 6a63a34 commit 377fce1

File tree

2 files changed

+16
-54
lines changed

2 files changed

+16
-54
lines changed

sdk/python/tests/integration/online_store/test_remote_online_store.py

Lines changed: 0 additions & 53 deletions
Original file line numberDiff line numberDiff line change
@@ -228,56 +228,3 @@ def _overwrite_remote_client_feature_store_yaml(
228228
)
229229
+ auth_config
230230
)
231-
232-
233-
def _start_feature_server(repo_path: str, server_port: int, metrics: bool = False):
234-
host = "0.0.0.0"
235-
cmd = [
236-
"feast",
237-
"-c" + repo_path,
238-
"serve",
239-
"--host",
240-
host,
241-
"--port",
242-
str(server_port),
243-
]
244-
feast_server_process = subprocess.Popen(
245-
cmd, stdout=subprocess.PIPE, stderr=subprocess.DEVNULL
246-
)
247-
_time_out_sec: int = 60
248-
# Wait for server to start
249-
wait_retry_backoff(
250-
lambda: (None, check_port_open(host, server_port)),
251-
timeout_secs=_time_out_sec,
252-
timeout_msg=f"Unable to start the feast server in {_time_out_sec} seconds for remote online store type, port={server_port}",
253-
)
254-
255-
if metrics:
256-
cmd.append("--metrics")
257-
258-
# Check if metrics are enabled and Prometheus server is running
259-
if metrics:
260-
wait_retry_backoff(
261-
lambda: (None, check_port_open("localhost", 8000)),
262-
timeout_secs=_time_out_sec,
263-
timeout_msg="Unable to start the Prometheus server in 60 seconds.",
264-
)
265-
else:
266-
assert not check_port_open(
267-
"localhost", 8000
268-
), "Prometheus server is running when it should be disabled."
269-
270-
yield f"http://localhost:{server_port}"
271-
272-
if feast_server_process is not None:
273-
feast_server_process.kill()
274-
275-
# wait server to free the port
276-
wait_retry_backoff(
277-
lambda: (
278-
None,
279-
not check_port_open("localhost", server_port),
280-
),
281-
timeout_msg=f"Unable to stop the feast server in {_time_out_sec} seconds for remote online store type, port={server_port}",
282-
timeout_secs=_time_out_sec,
283-
)

sdk/python/tests/utils/auth_permissions_util.py

Lines changed: 16 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -54,7 +54,7 @@ def default_store(
5454
return fs
5555

5656

57-
def start_feature_server(repo_path: str, server_port: int):
57+
def start_feature_server(repo_path: str, server_port: int, metrics: bool = False):
5858
host = "0.0.0.0"
5959
cmd = [
6060
"feast",
@@ -76,6 +76,21 @@ def start_feature_server(repo_path: str, server_port: int):
7676
timeout_msg=f"Unable to start the feast server in {_time_out_sec} seconds for remote online store type, port={server_port}",
7777
)
7878

79+
if metrics:
80+
cmd.append("--metrics")
81+
82+
# Check if metrics are enabled and Prometheus server is running
83+
if metrics:
84+
wait_retry_backoff(
85+
lambda: (None, check_port_open("localhost", 8000)),
86+
timeout_secs=_time_out_sec,
87+
timeout_msg="Unable to start the Prometheus server in 60 seconds.",
88+
)
89+
else:
90+
assert not check_port_open(
91+
"localhost", 8000
92+
), "Prometheus server is running when it should be disabled."
93+
7994
yield f"http://localhost:{server_port}"
8095

8196
if feast_server_process is not None:

0 commit comments

Comments
 (0)