Fix is_alive column type

dashboard/state_aggregator.py

@@ -147,7 +147,7 @@ def _filter(
 
  Returns:
  A list of filtered state data in dictionary. Each state data's
- unncessary columns are filtered by the given state_dataclass schema.
+ unnecessary columns are filtered by the given state_dataclass schema.
  """
  filters = _convert_filters_type(filters, state_dataclass)
  result = []

python/ray/experimental/state/common.py

@@ -310,7 +310,7 @@ def filterable_columns(cls) -> Set[str]:
 @dataclass(init=True)
 class WorkerState(StateSchema):
  worker_id: str = state_column(filterable=True)
- is_alive: str = state_column(filterable=True)
+ is_alive: bool = state_column(filterable=True)
  worker_type: str = state_column(filterable=True)
  exit_type: str = state_column(filterable=True)
  node_id: str = state_column(filterable=True)

python/ray/tests/test_state_api.py

@@ -2031,7 +2031,7 @@ def verify():
  wait_for_condition(verify)
 
  """
- Test filter with different types (integer).
+ Test filter with different types (integer/bool).
  """
  obj_1 = ray.put(123) # noqa
  ray.get(a.put.remote())
@@ -2046,6 +2046,24 @@ def verify():
 
  wait_for_condition(verify)
 
+ def verify():
+ workers = list_workers()
+ live_workers = list_workers(filters=[("is_alive", "=", "true")])
+ non_alive_workers = list_workers(filters=[("is_alive", "!=", "true")])
+ assert len(live_workers) + len(non_alive_workers) == len(workers)
+
+ live_workers = list_workers(filters=[("is_alive", "=", "1")])
+ non_alive_workers = list_workers(filters=[("is_alive", "!=", "1")])
+ assert len(live_workers) + len(non_alive_workers) == len(workers)
+
+ live_workers = list_workers(filters=[("is_alive", "=", "True")])
+ non_alive_workers = list_workers(filters=[("is_alive", "!=", "True")])
+ assert len(live_workers) + len(non_alive_workers) == len(workers)
+
+ return True
+
+ wait_for_condition(verify)
+
  """
  Test CLI
  """