Skip to content

Commit b8d7531

Browse files
committed
Fix unbound variable in entity V1 processing
1 parent c658a52 commit b8d7531

File tree

1 file changed

+5
-4
lines changed

1 file changed

+5
-4
lines changed

durabletask/worker.py

Lines changed: 5 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -740,21 +740,22 @@ def _execute_entity_batch(
740740
stub: Union[stubs.TaskHubSidecarServiceStub, ProtoTaskHubSidecarServiceStub],
741741
completionToken,
742742
):
743+
operation_infos: list[pb.OperationInfo] = []
743744
if isinstance(req, pb.EntityRequest):
744745
req, operation_infos = helpers.convert_to_entity_batch_request(req)
745746

746747
entity_state = StateShim(shared.from_json(req.entityState.value) if req.entityState.value else None)
747748

748749
instance_id = req.instanceId
750+
try:
751+
entity_instance_id = EntityInstanceId.parse(instance_id)
752+
except ValueError:
753+
raise RuntimeError(f"Invalid entity instance ID '{instance_id}' in entity operation request.")
749754

750755
results: list[pb.OperationResult] = []
751756
for operation in req.operations:
752757
start_time = datetime.now(timezone.utc)
753758
executor = _EntityExecutor(self._registry, self._logger)
754-
try:
755-
entity_instance_id = EntityInstanceId.parse(instance_id)
756-
except ValueError:
757-
raise RuntimeError(f"Invalid entity instance ID '{instance_id}' in entity operation request.")
758759

759760
operation_result = None
760761

0 commit comments

Comments
 (0)