fix: use incr for ws disconnect stats events

package.json

@@ -1,6 +1,6 @@
 {
     "name": "querybook",
-    "version": "3.23.1",
+    "version": "3.23.2",
     "description": "A Big Data Webapp",
     "private": true,
     "scripts": {

querybook/server/datasources_socketio/helper.py

@@ -19,8 +19,10 @@ def handler(*args, **kwargs):
             if not current_user.is_authenticated:
                 LOG.error("Unauthorized websocket access")
                 disconnect()
-                # decrement ws connections counter on disconnect
-                stats_logger.decr(WS_CONNECTIONS)
+                # incr ws connections counter on disconnect
+                stats_logger.incr(
+                    WS_CONNECTIONS, tags={"namespace": namespace, "event": "disconnect"}
+                )
             else:
                 try:
                     if websocket_logging:
@@ -41,10 +43,16 @@ def handler(*args, **kwargs):
 
                 # increment ws connections counter on connect
                 if url == "connect":
-                    stats_logger.incr(WS_CONNECTIONS, tags={"namespace": namespace})
-                # decrement ws connections counter on disconnect
+                    stats_logger.incr(
+                        WS_CONNECTIONS,
+                        tags={"namespace": namespace, "event": "connect"},
+                    )
+                # incr ws connections counter on disconnect
                 elif url == "disconnect":
-                    stats_logger.decr(WS_CONNECTIONS, tags={"namespace": namespace})
+                    stats_logger.incr(
+                        WS_CONNECTIONS,
+                        tags={"namespace": namespace, "event": "disconnect"},
+                    )
 
         handler.__raw__ = fn
         return handler

querybook/server/tasks/run_query.py

@@ -57,8 +57,6 @@ def run_query_task(
             7406, "{}\n{}".format(e, traceback.format_exc())
         )
     finally:
-        stats_logger.decr(QUERY_EXECUTIONS, tags={"execution_type": execution_type})
-
         # When the finally block is reached, it is expected
         # that the executor should be in one of the end state
         with DBSession() as session: