From fc3c2529330512a8190328e935832751cbf8918f Mon Sep 17 00:00:00 2001
From: Dominic Tarro <57306102+dominictarro@users.noreply.github.com>
Date: Mon, 26 Jun 2023 12:19:39 -0400
Subject: [PATCH] fix stream source path resolution

---
 prefect_aws/s3.py | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/prefect_aws/s3.py b/prefect_aws/s3.py
index cb5f4b64..17fe8870 100644
--- a/prefect_aws/s3.py
+++ b/prefect_aws/s3.py
@@ -828,7 +828,7 @@ async def stream_from(
             to_path = Path(from_path).name
 
         # Get the source object's StreamingBody
-        from_path: str = self._join_bucket_folder(from_path)
+        from_path: str = bucket._join_bucket_folder(from_path)
         from_client = bucket.credentials.get_s3_client()
         obj = await run_sync_in_worker_thread(
             from_client.get_object, Bucket=bucket.bucket_name, Key=from_path