Close request when initial response fails and propagate error (#454)

Author: alextwoods

codegen/core/src/main/java/software/amazon/smithy/python/codegen/ClientGenerator.java

@@ -320,9 +320,9 @@ async def _wrap_duplex_output(
                                     request_future, response_future,
                                 )
                             except Exception as e:
-                                if request_future is not None and not request_future.done:
+                                if request_future is not None and not request_future.done():
                                     request_future.set_exception($4T(e))
-                                if response_future is not None and not response_future.done:
+                                if response_future is not None and not response_future.done():
                                     response_future.set_exception($4T(e))
 
                                 # Make sure every exception that we throw is an instance of $4T so

packages/smithy-http/src/smithy_http/aio/crt.py

@@ -251,7 +251,12 @@ async def send(
         crt_stream.completion_future.add_done_callback(
             partial(self._close_input_body, body=crt_body)
         )
-        return await response_factory.await_response()
+
+        response = await response_factory.await_response()
+        if response.status != 200 and response.status >= 300:
+            await close(crt_body)
+
+        return response
 
     def _close_input_body(
         self, future: ConcurrentFuture[int], *, body: "BufferableByteStream | BytesIO"