Use internal ip for scheduler contact address

dbalabka · dbalabka · commit 3d13138a10c7 · 2025-07-09T17:40:21.000+03:00
diff --git a/dask_cloudprovider/generic/vmcluster.py b/dask_cloudprovider/generic/vmcluster.py
@@ -99,6 +99,8 @@ async def start(self):
                 f"{self.cluster.protocol}://{external_ip}:{self.port}"
             )
 
+        self.contact_address = f"{self.cluster.protocol}://{internal_ip}:{self.port}"
+
         await self.wait_for_scheduler()
         await super().start()
 

Original file line number	Diff line number	Diff line change
`@@ -99,6 +99,8 @@ async def start(self):`
`99`	`99`	`f"{self.cluster.protocol}://{external_ip}:{self.port}"`
`100`	`100`	`)`
`101`	`101`
	`102`	`+ self.contact_address = f"{self.cluster.protocol}://{internal_ip}:{self.port}"`
	`103`	`+`
`102`	`104`	`await self.wait_for_scheduler()`
`103`	`105`	`await super().start()`
`104`	`106`