File tree Expand file tree Collapse file tree 1 file changed +5
-4
lines changed
graphdatascience/query_runner Expand file tree Collapse file tree 1 file changed +5
-4
lines changed Original file line number Diff line number Diff line change @@ -18,8 +18,7 @@ def set(self) -> None:
1818 pass
1919
2020 def assert_running (self ) -> None :
21- if self .is_set ():
22- raise RuntimeError ("Query has been terminated" )
21+ pass
2322
2423 @staticmethod
2524 def create (signals : Optional [list [signal .Signals ]] = None ) -> TerminationFlag :
@@ -38,7 +37,7 @@ def __init__(self, signals: list[signal.Signals]) -> None:
3837 self ._event = threading .Event ()
3938
4039 def receive_signal (sig : int , frame : Optional [FrameType ]) -> None :
41- logging .debug (f"Received signal { sig } . Interrupting query ." )
40+ logging .info (f"Received signal { sig } ." )
4241 self ._event .set ()
4342
4443 for sig in signals :
@@ -52,7 +51,9 @@ def set(self) -> None:
5251
5352 def assert_running (self ) -> None :
5453 if self .is_set ():
55- raise RuntimeError ("Query has been terminated" )
54+ raise RuntimeError (
55+ "Closing client connection. Note, the query will be continued on the server-side"
56+ )
5657
5758
5859class TerminationFlagNoop (TerminationFlag ):
You can’t perform that action at this time.
0 commit comments