Skip to content

Commit

Permalink
REFORMATTED
Browse files Browse the repository at this point in the history
  • Loading branch information
jovany-wang committed Jul 21, 2023
1 parent bc0e97b commit 42a0ed8
Show file tree
Hide file tree
Showing 17 changed files with 38 additions and 38 deletions.
8 changes: 4 additions & 4 deletions README.md
Original file line number Diff line number Diff line change
Expand Up @@ -108,8 +108,8 @@ def main(party):
ray.init(address='local')

addresses = {
'alice': {'address': '127.0.0.1:11012'},
'bob': {'address': '127.0.0.1:11011'},
'alice': '127.0.0.1:11012',
'bob': '127.0.0.1:11011',
}
fed.init(addresses=addresses, party=party)
```
Expand Down Expand Up @@ -146,8 +146,8 @@ def main(party):
ray.init(address='local')

addresses = {
'alice': {'address': '127.0.0.1:11012'},
'bob': {'address': '127.0.0.1:11011'},
'alice': '127.0.0.1:11012',
'bob': '127.0.0.1:11011',
}
fed.init(addresses=addresses, party=party)

Expand Down
4 changes: 2 additions & 2 deletions tests/serializations_tests/test_unpickle_with_whitelist.py
Original file line number Diff line number Diff line change
Expand Up @@ -43,8 +43,8 @@ def pass_arg(d):
def run(party):
compatible_utils.init_ray(address='local')
addresses = {
'alice': {'address': '127.0.0.1:11012'},
'bob': {'address': '127.0.0.1:11011'},
'alice': '127.0.0.1:11012',
'bob': '127.0.0.1:11011',
}
allowed_list = {
"numpy.core.numeric": ["*"],
Expand Down
4 changes: 2 additions & 2 deletions tests/simple_example.py
Original file line number Diff line number Diff line change
Expand Up @@ -43,8 +43,8 @@ def agg_fn(obj1, obj2):


addresses = {
'alice': {'address': '127.0.0.1:11012'},
'bob': {'address': '127.0.0.1:11011'},
'alice': '127.0.0.1:11012',
'bob': '127.0.0.1:11011',
}


Expand Down
4 changes: 2 additions & 2 deletions tests/test_api.py
Original file line number Diff line number Diff line change
Expand Up @@ -23,7 +23,7 @@
def run():
compatible_utils.init_ray(address='local')
addresses = {
'alice': {'address': '127.0.0.1:11012'},
'alice': '127.0.0.1:11012',
}
fed.init(addresses=addresses, party="alice")
config = fed_config.get_cluster_config()
Expand All @@ -44,7 +44,7 @@ def test_miss_party_name_on_actor():
def run():
compatible_utils.init_ray(address='local')
addresses = {
'alice': {'address': '127.0.0.1:11012'},
'alice': '127.0.0.1:11012',
}
fed.init(addresses=addresses, party="alice")

Expand Down
4 changes: 2 additions & 2 deletions tests/test_async_startup_2_clusters.py
Original file line number Diff line number Diff line change
Expand Up @@ -44,8 +44,8 @@ def _run(party: str):

compatible_utils.init_ray(address='local')
addresses = {
'alice': {'address': '127.0.0.1:11012'},
'bob': {'address': '127.0.0.1:11011'},
'alice': '127.0.0.1:11012',
'bob': '127.0.0.1:11011',
}
fed.init(addresses=addresses, party=party)

Expand Down
4 changes: 2 additions & 2 deletions tests/test_basic_pass_fed_objects.py
Original file line number Diff line number Diff line change
Expand Up @@ -37,8 +37,8 @@ def get_value(self):
def run(party, is_inner_party):
compatible_utils.init_ray(address='local')
addresses = {
'alice': {'address': '127.0.0.1:11012'},
'bob': {'address': '127.0.0.1:11011'},
'alice': '127.0.0.1:11012',
'bob': '127.0.0.1:11011',
}
fed.init(addresses=addresses, party=party)

Expand Down
4 changes: 2 additions & 2 deletions tests/test_cache_fed_objects.py
Original file line number Diff line number Diff line change
Expand Up @@ -33,8 +33,8 @@ def g(x, index):
def run(party):
compatible_utils.init_ray(address='local')
addresses = {
'alice': {'address': '127.0.0.1:11012'},
'bob': {'address': '127.0.0.1:11011'},
'alice': '127.0.0.1:11012',
'bob': '127.0.0.1:11011',
}
fed.init(addresses=addresses, party=party)

Expand Down
4 changes: 2 additions & 2 deletions tests/test_enable_tls_across_parties.py
Original file line number Diff line number Diff line change
Expand Up @@ -49,8 +49,8 @@ def _run(party: str):
}

addresses = {
'alice': {'address': '127.0.0.1:11012'},
'bob': {'address': '127.0.0.1:11011'},
'alice': '127.0.0.1:11012',
'bob': '127.0.0.1:11011',
}
fed.init(addresses=addresses, party=party, tls_config=cert_config)

Expand Down
4 changes: 2 additions & 2 deletions tests/test_grpc_options_on_proxies.py
Original file line number Diff line number Diff line change
Expand Up @@ -27,8 +27,8 @@ def dummpy():
def run(party):
compatible_utils.init_ray(address='local')
addresses = {
'alice': {'address': '127.0.0.1:11019'},
'bob': {'address': '127.0.0.1:11018'},
'alice': '127.0.0.1:11019',
'bob': '127.0.0.1:11018',
}
fed.init(
addresses=addresses,
Expand Down
4 changes: 2 additions & 2 deletions tests/test_options.py
Original file line number Diff line number Diff line change
Expand Up @@ -34,8 +34,8 @@ def bar(x):
def run(party):
compatible_utils.init_ray(address='local')
addresses = {
'alice': {'address': '127.0.0.1:11012'},
'bob': {'address': '127.0.0.1:11011'},
'alice': '127.0.0.1:11012',
'bob': '127.0.0.1:11011',
}
fed.init(addresses=addresses, party=party)

Expand Down
4 changes: 2 additions & 2 deletions tests/test_pass_fed_objects_in_containers_in_actor.py
Original file line number Diff line number Diff line change
Expand Up @@ -38,8 +38,8 @@ def bar(self, li):


addresses = {
'alice': {'address': '127.0.0.1:11012'},
'bob': {'address': '127.0.0.1:11011'},
'alice': '127.0.0.1:11012',
'bob': '127.0.0.1:11011',
}


Expand Down
4 changes: 2 additions & 2 deletions tests/test_pass_fed_objects_in_containers_in_normal_tasks.py
Original file line number Diff line number Diff line change
Expand Up @@ -40,8 +40,8 @@ def bar(li):
def run(party):
compatible_utils.init_ray(address='local')
addresses = {
'alice': {'address': '127.0.0.1:11012'},
'bob': {'address': '127.0.0.1:11011'},
'alice': '127.0.0.1:11012',
'bob': '127.0.0.1:11011',
}
fed.init(addresses=addresses, party=party)
o1 = foo.party("alice").remote(0)
Expand Down
4 changes: 2 additions & 2 deletions tests/test_ping_others.py
Original file line number Diff line number Diff line change
Expand Up @@ -21,8 +21,8 @@


addresses = {
'alice': {'address': '127.0.0.1:11012'},
'bob': {'address': '127.0.0.1:11011'},
'alice': '127.0.0.1:11012',
'bob': '127.0.0.1:11011',
}


Expand Down
4 changes: 2 additions & 2 deletions tests/test_repeat_init.py
Original file line number Diff line number Diff line change
Expand Up @@ -38,8 +38,8 @@ def bar(self, li):


addresses = {
'alice': {'address': '127.0.0.1:11012'},
'bob': {'address': '127.0.0.1:11011'},
'alice': '127.0.0.1:11012',
'bob': '127.0.0.1:11011',
}


Expand Down
4 changes: 2 additions & 2 deletions tests/test_reset_context.py
Original file line number Diff line number Diff line change
Expand Up @@ -5,8 +5,8 @@
import pytest

addresses = {
'alice': {'address': '127.0.0.1:11012'},
'bob': {'address': '127.0.0.1:11011'},
'alice': '127.0.0.1:11012',
'bob': '127.0.0.1:11011',
}


Expand Down
4 changes: 2 additions & 2 deletions tests/test_retry_policy.py
Original file line number Diff line number Diff line change
Expand Up @@ -40,8 +40,8 @@ def get_value(self):
def run(party, is_inner_party):
compatible_utils.init_ray(address='local')
addresses = {
'alice': {'address': '127.0.0.1:11012'},
'bob': {'address': '127.0.0.1:11011'},
'alice': '127.0.0.1:11012',
'bob': '127.0.0.1:11011',
}
retry_policy = {
"maxAttempts": 4,
Expand Down
8 changes: 4 additions & 4 deletions tests/test_setup_proxy_actor.py
Original file line number Diff line number Diff line change
Expand Up @@ -26,8 +26,8 @@
def run(party):
compatible_utils.init_ray(address='local', resources={"127.0.0.1": 2})
addresses = {
'alice': {'address': '127.0.0.1:11010'},
'bob': {'address': '127.0.0.1:11011'},
'alice': '127.0.0.1:11010',
'bob': '127.0.0.1:11011',
}
sender_proxy_resources = {
"127.0.0.1": 1
Expand All @@ -52,8 +52,8 @@ def run(party):
def run_failure(party):
compatible_utils.init_ray(address='local', resources={"127.0.0.1": 1})
addresses = {
'alice': {'address': '127.0.0.1:11010'},
'bob': {'address': '127.0.0.1:11011'},
'alice': '127.0.0.1:11010',
'bob': '127.0.0.1:11011',
}
sender_proxy_resources = {
"127.0.0.2": 1 # Insufficient resource
Expand Down

0 comments on commit 42a0ed8

Please sign in to comment.