Merge branch 'main' into andystaples/add-inprocess-test-backend

Author: andystaples

CHANGELOG.md

@@ -5,11 +5,19 @@ All notable changes to this project will be documented in this file.
 The format is based on [Keep a Changelog](https://keepachangelog.com/en/1.0.0/),
 and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0.html).
 
+<<<<<<< andystaples/add-inprocess-test-backend
 ## 1.4.0
 
 ADDED
 
 - Added `durabletask.testing` module with `InMemoryOrchestrationBackend` for testing orchestrations without a sidecar process
+=======
+## Unreleased
+
+FIXED:
+
+- Fix unbound variable in entity V1 processing
+>>>>>>> main
 
 ## v1.3.0
 

durabletask/worker.py

@@ -740,21 +740,22 @@ def _execute_entity_batch(
             stub: Union[stubs.TaskHubSidecarServiceStub, ProtoTaskHubSidecarServiceStub],
             completionToken,
     ):
+        operation_infos: list[pb.OperationInfo] = []
         if isinstance(req, pb.EntityRequest):
             req, operation_infos = helpers.convert_to_entity_batch_request(req)
 
         entity_state = StateShim(shared.from_json(req.entityState.value) if req.entityState.value else None)
 
         instance_id = req.instanceId
+        try:
+            entity_instance_id = EntityInstanceId.parse(instance_id)
+        except ValueError:
+            raise RuntimeError(f"Invalid entity instance ID '{instance_id}' in entity operation request.")
 
         results: list[pb.OperationResult] = []
         for operation in req.operations:
             start_time = datetime.now(timezone.utc)
             executor = _EntityExecutor(self._registry, self._logger)
-            try:
-                entity_instance_id = EntityInstanceId.parse(instance_id)
-            except ValueError:
-                raise RuntimeError(f"Invalid entity instance ID '{instance_id}' in entity operation request.")
 
             operation_result = None