Skip to content
Open
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
4 changes: 2 additions & 2 deletions packages/syft/src/syft/protocol/data_protocol.py
Original file line number Diff line number Diff line change
Expand Up @@ -224,12 +224,12 @@ def obj_json(version: str | int, _hash: str, action: str = "add") -> dict:
def diff_state(self, state: dict) -> tuple[dict, dict]:
compare_dict: dict = defaultdict(dict) # what versions are in the latest code
object_diff: dict = defaultdict(dict) # diff in latest code with saved json
all_serde_propeties = [
all_serde_properties = [
serde_properties
for version_dict in SyftObjectRegistry.__object_serialization_registry__.values()
for serde_properties in version_dict.values()
]
for serde_properties in all_serde_propeties:
for serde_properties in all_serde_properties:
cls, version = serde_properties[7], serde_properties[9]
if issubclass(cls, SyftBaseObject):
canonical_name = cls.__canonical_name__
Expand Down
2 changes: 1 addition & 1 deletion packages/syft/src/syft/service/code/user_code.py
Original file line number Diff line number Diff line change
Expand Up @@ -1286,7 +1286,7 @@ def _ephemeral_server_call(
def task() -> None:
if "blocking" in kwargs and not kwargs["blocking"]:
time.sleep(time_alive)
print(SyftInfo(message="Landing the ephmeral server..."))
print(SyftInfo(message="Landing the ephemeral server..."))
ep_server.land()
print(SyftInfo(message="Server Landed!"))

Expand Down
2 changes: 1 addition & 1 deletion packages/syft/src/syft/service/log/log_service.py
Original file line number Diff line number Diff line change
Expand Up @@ -85,7 +85,7 @@ def get_all(self, context: AuthedServiceContext) -> list[SyftLog]:
@service_method(path="log.delete", name="delete", roles=DATA_SCIENTIST_ROLE_LEVEL)
def delete(self, context: AuthedServiceContext, uid: UID) -> SyftSuccess:
self.stash.delete_by_uid(context.credentials, uid).unwrap()
return SyftSuccess(message=f"log {uid} succesfully deleted")
return SyftSuccess(message=f"log {uid} successfully deleted")

@service_method(
path="log.has_storage_permission",
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -242,7 +242,7 @@ def turn_off(
notifier.active = False
self.stash.update(credentials=context.credentials, obj=notifier).unwrap()
context.server.services.settings.update(context, notifications_enabled=False)
return SyftSuccess(message="Notifications disabled succesfullly")
return SyftSuccess(message="Notifications disabled successfully")

@as_result(SyftException)
def activate(
Expand Down
2 changes: 1 addition & 1 deletion packages/syft/src/syft/service/queue/zmq_consumer.py
Original file line number Diff line number Diff line change
Expand Up @@ -212,7 +212,7 @@ def _run(self) -> None:
logger.error(f"ZMQConsumer invalid recv: {msg}")
continue

# Message frames recieved by consumer:
# Message frames received by consumer:
# [empty, header, command, ...data]
(_, _, command, *data) = msg

Expand Down
4 changes: 2 additions & 2 deletions packages/syft/src/syft/types/syft_object.py
Original file line number Diff line number Diff line change
Expand Up @@ -555,7 +555,7 @@ def __getitem__(self, key: str | int) -> Any:
def to(self, projection: type[T], context: Context | None = None) -> T:
# relative

# 🟡 TODO 19: Could we do an mro style inheritence conversion? Risky?
# 🟡 TODO 19: Could we do an mro style inheritance conversion? Risky?
transform = SyftObjectRegistry.get_transform(type(self), projection)
return transform(self, context)

Expand Down Expand Up @@ -792,7 +792,7 @@ def short_uid(uid: UID | None) -> str | None:

class StorableObjectType:
def to(self, projection: type, context: Context | None = None) -> Any:
# 🟡 TODO 19: Could we do an mro style inheritence conversion? Risky?
# 🟡 TODO 19: Could we do an mro style inheritance conversion? Risky?
# relative

transform = SyftObjectRegistry.get_transform(type(self), projection)
Expand Down
4 changes: 2 additions & 2 deletions packages/syft/src/syft/util/test_helpers/apis/live/schema.py
Original file line number Diff line number Diff line change
Expand Up @@ -97,12 +97,12 @@ def live_schema(
if not hasattr(e, "_errors"):
output = f"got exception e: {type(e)} {str(e)}"
raise SyftException(
public_message=f"An error occured executing the API call {output}"
public_message=f"An error occurred executing the API call {output}"
)

# Should add appropriate error handling for what should be exposed to the data scientists.
raise SyftException(
public_message="An error occured executing the API call, please contact the domain owner."
public_message="An error occurred executing the API call, please contact the domain owner."
)

return live_schema
Original file line number Diff line number Diff line change
Expand Up @@ -79,7 +79,7 @@ def live_test_query(
if not hasattr(e, "_errors"):
output = f"got exception e: {type(e)} {str(e)}"
raise SyftException(
public_message=f"An error occured executing the API call {output}"
public_message=f"An error occurred executing the API call {output}"
)

# Treat all errors that we would like to be forwarded to the data scientists
Expand All @@ -102,12 +102,12 @@ def live_test_query(
"timeout",
]:
raise SyftException(
public_message="Error occured during the call: "
public_message="Error occurred during the call: "
+ e._errors[0]["message"]
)
else:
raise SyftException(
public_message="An error occured executing the API call, please contact the domain owner."
public_message="An error occurred executing the API call, please contact the domain owner."
)

return live_test_query