Skip to content

Commit 564e0de

Browse files
committed
Entity-related typing changes
1 parent 227e01b commit 564e0de

File tree

3 files changed

+6
-3
lines changed

3 files changed

+6
-3
lines changed

durabletask/client.py

Lines changed: 4 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -230,7 +230,10 @@ def purge_orchestration(self, instance_id: str, recursive: bool = True):
230230
self._logger.info(f"Purging instance '{instance_id}'.")
231231
self._stub.PurgeInstances(req)
232232

233-
def signal_entity(self, entity_instance_id: EntityInstanceId, operation_name: str, input: Optional[Any] = None):
233+
def signal_entity(self,
234+
entity_instance_id: EntityInstanceId,
235+
operation_name: str,
236+
input: Optional[Any] = None) -> None:
234237
req = pb.SignalEntityRequest(
235238
instanceId=str(entity_instance_id),
236239
name=operation_name,

durabletask/task.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -142,7 +142,7 @@ def call_activity(self, activity: Union[Activity[TInput, TOutput], str], *,
142142
def call_entity(self,
143143
entity: EntityInstanceId,
144144
operation: str,
145-
input: Optional[TInput] = None) -> CompletableTask:
145+
input: Optional[TInput] = None) -> CompletableTask[Any]:
146146
"""Schedule entity function for execution.
147147
148148
Parameters

durabletask/worker.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1047,7 +1047,7 @@ def call_entity(
10471047
entity: EntityInstanceId,
10481048
operation: str,
10491049
input: Optional[TInput] = None,
1050-
) -> task.CompletableTask:
1050+
) -> task.CompletableTask[Any]:
10511051
id = self.next_sequence_number()
10521052

10531053
self.call_entity_function_helper(

0 commit comments

Comments
 (0)