diff --git a/python/ray/autoscaler/_private/fake_multi_node/node_provider.py b/python/ray/autoscaler/_private/fake_multi_node/node_provider.py index 968d00175..27a01abc7 100644 --- a/python/ray/autoscaler/_private/fake_multi_node/node_provider.py +++ b/python/ray/autoscaler/_private/fake_multi_node/node_provider.py @@ -268,6 +268,8 @@ class FakeMultiNodeProvider(NodeProvider): raise AssertionError("Readonly node provider cannot be updated") def create_node_with_resources(self, node_config, tags, count, resources): + resources = resources.copy() + with self.lock: node_type = tags[TAG_RAY_USER_NODE_TYPE] next_id = self._next_hex_node_id()