fix stream source path resolution

PrefectHQ · Jun 26, 2023 · fc3c252 · fc3c252
1 parent f287c23
commit fc3c252
Showing 1 changed file with 1 addition and 1 deletion.
diff --git 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