File tree Expand file tree Collapse file tree 1 file changed +11
-1
lines changed
rust/cubesql/cubesql/src/sql/postgres Expand file tree Collapse file tree 1 file changed +11
-1
lines changed Original file line number Diff line number Diff line change 1- use std:: { backtrace:: Backtrace , collections:: HashMap , sync:: Arc } ;
1+ use std:: { backtrace:: Backtrace , collections:: HashMap , io :: ErrorKind , sync:: Arc } ;
22
33use super :: extended:: PreparedStatement ;
44use crate :: {
@@ -191,6 +191,16 @@ impl AsyncPostgresShim {
191191
192192 match shim. run ( ) . await {
193193 Err ( e) => {
194+ if let ConnectionError :: Protocol ( ProtocolError :: IO { source, .. } ) = & e {
195+ if source. kind ( ) == ErrorKind :: BrokenPipe
196+ || source. kind ( ) == ErrorKind :: UnexpectedEof
197+ {
198+ trace ! ( "Error during processing PostgreSQL connection: {}" , e) ;
199+
200+ return Ok ( ( ) ) ;
201+ }
202+ }
203+
194204 shim. logger . error (
195205 format ! ( "Error during processing PostgreSQL connection: {}" , e) . as_str ( ) ,
196206 None ,
You can’t perform that action at this time.
0 commit comments