Enhance the value error when missing a reqiured param.

fed/_private/fed_call_holder.py

@@ -56,6 +56,9 @@ def options(self, **options):
  return self
 
  def internal_remote(self, *args, **kwargs):
+ if self._node_party is None or len(self._node_party) == 0:
+ raise ValueError("You should specify a party name on the fed actor.")
+
  # Generate a new fed task id for this call.
  fed_task_id = get_global_context().next_seq_id()
  if self._party == self._node_party:

tests/test_api.py

@@ -40,6 +40,24 @@ def test_fed_apis():
  assert p_alice.exitcode == 0
 
 
+def test_miss_party_name_on_actor():
+ compatible_utils.init_ray(address='local')
+ cluster = {
+ 'alice': {'address': '127.0.0.1:11012'},
+ }
+ fed.init(cluster=cluster, party="alice")
+
+ @fed.remote
+ class MyActor:
+ pass
+
+ with pytest.raises(ValueError):
+ MyActor.remote()
+
+ fed.shutdown()
+ ray.shutdown()
+
+
 if __name__ == "__main__":
  import sys