diff --git a/integrations/azure/poetry.lock b/integrations/azure/poetry.lock
index 1fc17d5eef..83c685ed51 100644
--- a/integrations/azure/poetry.lock
+++ b/integrations/azure/poetry.lock
@@ -138,18 +138,21 @@ frozenlist = ">=1.1.0"
 
 [[package]]
 name = "aiostream"
-version = "0.5.2"
+version = "0.6.2"
 description = "Generator-based operators for asynchronous iteration"
 optional = false
 python-versions = ">=3.8"
 files = [
-    {file = "aiostream-0.5.2-py3-none-any.whl", hash = "sha256:054660370be9d37f6fe3ece3851009240416bd082e469fd90cc8673d3818cf71"},
-    {file = "aiostream-0.5.2.tar.gz", hash = "sha256:b71b519a2d66c38f0872403ab86417955b77352f08d9ad02ad46fc3926b389f4"},
+    {file = "aiostream-0.6.2-py3-none-any.whl", hash = "sha256:e771bfb0a8d6f5e04359992025315fa4cc3b908ddb02822f73bb57d6ed7e9125"},
+    {file = "aiostream-0.6.2.tar.gz", hash = "sha256:481e58c7f94b98f37a81384411ee39336dffb933784753b1cfa0a26f3681cc2c"},
 ]
 
 [package.dependencies]
 typing-extensions = "*"
 
+[package.extras]
+dev = ["pytest", "pytest-asyncio", "pytest-cov"]
+
 [[package]]
 name = "anyio"
 version = "4.4.0"
@@ -2659,4 +2662,4 @@ multidict = ">=4.0"
 [metadata]
 lock-version = "2.0"
 python-versions = "^3.11"
-content-hash = "34d7a6002ce3aaf64d84d759417262be3fef59a59ac4ef383d3228f7b5686cc0"
+content-hash = "4151a0f9b9d39a011a8564d0e57e0b0e6f36d9948a3240cd138f3cfb0fa93515"
diff --git a/integrations/azure/pyproject.toml b/integrations/azure/pyproject.toml
index 3c9c5ee2a6..7a28873de1 100644
--- a/integrations/azure/pyproject.toml
+++ b/integrations/azure/pyproject.toml
@@ -13,7 +13,7 @@ azure-identity = "^1.13.0"
 aiohttp = "^3.9.4"
 cloudevents = "^1.9.0"
 azure-mgmt-subscription = "^3.1.1"
-aiostream = "^0.5.2"
+aiostream = "^0.6.0"
 
 [tool.poetry.group.dev.dependencies]
 # Uncomment this if you want to debug the ocean core together with your integration