Skip to content

Commit

Permalink
Remove misleading address
Browse files Browse the repository at this point in the history
Signed-off-by: Jason Parraga <[email protected]>
  • Loading branch information
Sovietaced committed Oct 27, 2024
1 parent 5a8941b commit b2654c4
Showing 1 changed file with 1 addition and 2 deletions.
3 changes: 1 addition & 2 deletions plugins/flytekit-ray/flytekitplugins/ray/task.py
Original file line number Diff line number Diff line change
Expand Up @@ -43,7 +43,6 @@ class RayJobConfig:
head_node_config: typing.Optional[HeadNodeConfig] = None
enable_autoscaling: bool = False
runtime_env: typing.Optional[dict] = None
address: typing.Optional[str] = None
shutdown_after_job_finishes: bool = False
ttl_seconds_after_finished: typing.Optional[int] = None

Expand All @@ -65,7 +64,7 @@ def __init__(self, task_config: RayJobConfig, task_function: Callable, **kwargs)
self._task_config = task_config

def pre_execute(self, user_params: ExecutionParameters) -> ExecutionParameters:
init_params = {"address": self._task_config.address}
init_params = {}

ctx = FlyteContextManager.current_context()
if not ctx.execution_state.is_local_execution():
Expand Down

0 comments on commit b2654c4

Please sign in to comment.